芝麻web文件管理V1.00

编辑当前文件:/home/digitalh/network.digitalhubbd.com/fns/load/private_conversations.php

<?php

use Medoo\Medoo;

if (role(['permissions' => ['private_conversations' => 'view_private_chats']])) {

$current_user_id = Registry::load('current_user')->id;

$columns = [
        'recipient.display_name(recipient_name)', 'initiator.display_name(initiator_name)',
        'recipient.username(recipient_username)', 'initiator.username(initiator_username)',
        'recipient.profile_picture(recipient_picture)', 'initiator.profile_picture(initiator_picture)',
        'recipient.online_status(recipient_online_status)', 'initiator.online_status(initiator_online_status)',
        'recipient.stay_online(recipient_stay_online)', 'initiator.stay_online(initiator_stay_online)',
        'recipient_settings.offline_mode(recipient_offline_mode)', 'initiator_settings.offline_mode(initiator_offline_mode)',
        'private_conversations.initiator_user_id', 'private_conversations.recipient_user_id', 'private_conversations.private_conversation_id',
        'blacklist_recipient.block(blocked_recipient)', 'blacklist_initiator.block(blocked_initiator)',
        'ignore_recipient.ignore(ignored_recipient)', 'ignore_initiator.ignore(ignored_initiator)',
    ];

$columns['unread_messages'] = Medoo::raw('(SELECT count(<private_chat_message_id>) FROM <private_chat_messages> WHERE <user_id> != :current_user_id AND <private_conversation_id> = <private_conversations.private_conversation_id> AND <read_status> = 0)', ['current_user_id' => $current_user_id]);
    $columns['last_message_content'] = Medoo::raw('(SELECT <filtered_message> FROM <private_chat_messages> WHERE <private_conversation_id> = <private_conversations.private_conversation_id> AND <private_chat_messages.system_message> != 1 ORDER BY <private_chat_message_id> DESC LIMIT 1)', ['current_user_id' => $current_user_id]);
    $columns['last_message_attachment'] = Medoo::raw('(SELECT <attachment_type> FROM <private_chat_messages> WHERE <private_conversation_id> = <private_conversations.private_conversation_id> ORDER BY <private_chat_message_id> DESC LIMIT 1)', ['current_user_id' => $current_user_id]);

$last_msg_sql = '(SELECT <private_chat_message_id> FROM <private_chat_messages> ';
    $last_msg_sql .= 'WHERE <private_conversation_id> = <private_conversations.private_conversation_id> ';
    $last_msg_sql .= 'AND <private_chat_message_id> > (SELECT IF(<recipient_user_id> = :current_user_id, ';
    $last_msg_sql .= '(IF(<recipient_load_message_id_from> IS NULL, 0, <recipient_load_message_id_from>)), ';
    $last_msg_sql .= '(IF(<initiator_load_message_id_from> IS NULL, 0, <initiator_load_message_id_from>)))';
    $last_msg_sql .= ') LIMIT 1)';

$columns['last_message_id'] = Medoo::raw($last_msg_sql);

$check_blocked_sql = 'IFNULL((SELECT <block> FROM <site_users_blacklist> ';
    $check_blocked_sql .= 'WHERE <user_id> = :current_user_id ';
    $check_blocked_sql .= 'AND <blacklisted_user_id> = (SELECT IF(<recipient_user_id> = :current_user_id, ';
    $check_blocked_sql .= 'initiator_user_id, recipient_user_id)';
    $check_blocked_sql .= ') LIMIT 1), 0)';

$columns['user_blocked'] = Medoo::raw($check_blocked_sql);

$check_blocked_sql = 'IFNULL((SELECT <ignore> FROM <site_users_blacklist> ';
    $check_blocked_sql .= 'WHERE <user_id> = :current_user_id ';
    $check_blocked_sql .= 'AND <blacklisted_user_id> = (SELECT IF(<recipient_user_id> = :current_user_id, ';
    $check_blocked_sql .= 'initiator_user_id, recipient_user_id)';
    $check_blocked_sql .= ') LIMIT 1), 0)';

$columns['user_ignored'] = Medoo::raw($check_blocked_sql);

$join["[>]site_users(recipient)"] = ["private_conversations.recipient_user_id" => "user_id"];
    $join["[>]site_users(initiator)"] = ["private_conversations.initiator_user_id" => "user_id"];

$join["[>]site_users_settings(recipient_settings)"] = ["private_conversations.recipient_user_id" => "user_id"];
    $join["[>]site_users_settings(initiator_settings)"] = ["private_conversations.initiator_user_id" => "user_id"];

$join["[>]site_users_blacklist(blacklist_recipient)"] = ["private_conversations.recipient_user_id" => "user_id", "AND" => ["blacklist_recipient.blacklisted_user_id" => Registry::load('current_user')->id]];
    $join["[>]site_users_blacklist(blacklist_initiator)"] = ["private_conversations.initiator_user_id" => "user_id", "AND" => ["blacklist_initiator.blacklisted_user_id" => Registry::load('current_user')->id]];

$join["[>]site_users_blacklist(ignore_recipient)"] = ["private_conversations.recipient_user_id" => "blacklisted_user_id", "AND" => ["ignore_recipient.user_id" => Registry::load('current_user')->id]];
    $join["[>]site_users_blacklist(ignore_initiator)"] = ["private_conversations.initiator_user_id" => "blacklisted_user_id", "AND" => ["ignore_initiator.user_id" => Registry::load('current_user')->id]];

if (!empty($data["offset"])) {
        $data["offset"] = array_map('intval', explode(',', $data["offset"]));
        $where["private_conversations.private_conversation_id[!]"] = $data["offset"];
    }

if (!empty($data["search"])) {
        $where["AND #search_query"]["OR"]["AND #first_query"] = [
            "recipient.display_name[~]" => $data["search"],
            "recipient.user_id[!]" => $current_user_id,
        ];

$where["AND #search_query"]["OR"]["AND #second_query"] = [
            "initiator.display_name[~]" => $data["search"],
            "initiator.user_id[!]" => $current_user_id,
        ];

$where["AND #search_query"]["OR"]["AND #third_query"] = [
            "recipient.username[~]" => $data["search"],
            "recipient.user_id[!]" => $current_user_id,
        ];

$where["AND #search_query"]["OR"]["AND #fourth_query"] = [
            "initiator.username[~]" => $data["search"],
            "initiator.user_id[!]" => $current_user_id,
        ];
    }

$where["AND"]["OR #first_query"] = [
        "private_conversations.initiator_user_id" => $current_user_id,
        "private_conversations.recipient_user_id" => $current_user_id,
    ];

if ($data["filter"] === 'blocked') {
        $where["HAVING"] = [
            "last_message_id[!]" => NULL,
            "user_blocked" => 1
        ];
    } else {
        $where["HAVING"] = [
            "last_message_id[!]" => NULL,
            "user_blocked[!]" => 1
        ];
    }

$where["LIMIT"] = Registry::load('settings')->records_per_call;

$where["ORDER"] = ["private_conversations.updated_on" => "DESC"];
    $conversations = DB::connect()->select('private_conversations', $join, $columns, $where);

$i = 1;
    $output = array();
    $output['loaded'] = new stdClass();
    $output['loaded']->title = Registry::load('strings')->messages;
    $output['loaded']->offset = array();
    $blocked_by_user = false;

if (!empty($data["offset"])) {
        $output['loaded']->offset = $data["offset"];
    }

$output['filters'][1] = new stdClass();
    $output['filters'][1]->filter = Registry::load('strings')->messages;
    $output['filters'][1]->class = 'load_aside';
    $output['filters'][1]->attributes['load'] = 'private_conversations';

$output['filters'][2] = new stdClass();
    $output['filters'][2]->filter = Registry::load('strings')->blocked;
    $output['filters'][2]->class = 'load_aside';
    $output['filters'][2]->attributes['load'] = 'private_conversations';
    $output['filters'][2]->attributes['filter'] = 'blocked';

if (role(['permissions' => ['site_users' => 'view_site_users']])) {
        $output['todo'] = new stdClass();
        $output['todo']->class = 'load_aside';
        $output['todo']->title = Registry::load('strings')->site_users;
        $output['todo']->attributes['load'] = 'site_users';
    } elseif (role(['permissions' => ['site_users' => 'view_online_users']])) {
        $output['todo'] = new stdClass();
        $output['todo']->class = 'load_aside';
        $output['todo']->title = Registry::load('strings')->online;
        $output['todo']->attributes['load'] = 'online';
    }

foreach ($conversations as $conversation) {

$output['loaded']->offset[] = $conversation['private_conversation_id'];
        $blocked_by_user = false;
        $ignored_user = false;

if ((int)$conversation['initiator_user_id'] === (int)$current_user_id) {
            $user_id = $conversation['recipient_user_id'];
            $display_name = $conversation['recipient_name'];
            $user_name = $conversation['recipient_username'];
            $online_status = $conversation['recipient_online_status'];
            $offline_mode = $conversation['recipient_offline_mode'];
            $profile_picture = $conversation['recipient_picture'];
            $stay_online = $conversation['recipient_stay_online'];

if (isset($conversation['blocked_recipient']) && !empty($conversation['blocked_recipient'])) {
                $blocked_by_user = true;
            }

} else {
            $user_id = $conversation['initiator_user_id'];
            $display_name = $conversation['initiator_name'];
            $user_name = $conversation['initiator_username'];
            $online_status = $conversation['initiator_online_status'];
            $offline_mode = $conversation['initiator_offline_mode'];
            $profile_picture = $conversation['initiator_picture'];
            $stay_online = $conversation['initiator_stay_online'];

if (isset($conversation['blocked_initiator']) && !empty($conversation['blocked_initiator'])) {
                $blocked_by_user = true;
            }

}

if (isset($conversation['ignored_recipient']) && !empty($conversation['ignored_recipient']) || isset($conversation['ignored_initiator']) && !empty($conversation['ignored_initiator'])) {
            $ignored_user = true;
        }

$output['content'][$i] = new stdClass();

if ($blocked_by_user && !role(['permissions' => ['site_users' => 'edit_users']])) {
            $output['content'][$i]->image = Registry::load('config')->site_url.'assets/files/site_users/profile_pics/default.png';
        } else {
            $output['content'][$i]->image = get_img_url(['from' => 'site_users/profile_pics', 'image' => $profile_picture]);
        }

$output['content'][$i]->title = $display_name;
        $output['content'][$i]->class = "private_conversation load_conversation";
        $output['content'][$i]->icon = 0;
        $output['content'][$i]->unread = 0;
        $output['content'][$i]->subtitle = '@'.$user_name;
        $output['content'][$i]->attributes = ['user_id' => $user_id, 'stopPropagation' => true];

if (empty($data["filter"]) && empty($data["sortby"]) && empty($data["search"])) {
            if (isset($conversation['unread_messages']) && !empty($conversation['unread_messages']) && !$ignored_user) {
                $output['content'][$i]->unread = abbreviateNumber($conversation['unread_messages']);
            }
        }

$show_message_preview = true;

if ($show_message_preview) {
            if (isset($conversation['last_message_content'])) {
                $output['content'][$i]->subtitle = strip_tags($conversation['last_message_content'], "<span>");
            }

if (empty($output['content'][$i]->subtitle)) {
                if (isset($conversation['last_message_attachment'])) {
                    if ($conversation['last_message_attachment'] === 'screenshot') {
                        $output['content'][$i]->subtitle = Registry::load('strings')->screenshot;
                    } else if ($conversation['last_message_attachment'] === 'gif') {
                        $output['content'][$i]->subtitle = Registry::load('strings')->gif;
                    } else if ($conversation['last_message_attachment'] === 'sticker') {
                        $output['content'][$i]->subtitle = Registry::load('strings')->sticker;
                    } else if ($conversation['last_message_attachment'] === 'audio_message') {
                        $output['content'][$i]->subtitle = Registry::load('strings')->audio_message;
                    } else {
                        $output['content'][$i]->subtitle = Registry::load('strings')->attachments;
                    }

}
            }
        }

if (empty($output['content'][$i]->subtitle)) {
            $output['content'][$i]->subtitle = '@'.$user_name;
        }

if (role(['permissions' => ['site_users' => 'view_online_users']])) {

if ((int)$online_status === 1) {
                $output['content'][$i]->online_status = 'online';
            } else if ((int)$online_status === 2) {
                $output['content'][$i]->online_status = 'idle';
            }

if ((int)$stay_online === 1) {
                $output['content'][$i]->online_status = 'online';
            }

if ((int)$offline_mode === 1) {
                if (!role(['permissions' => ['site_users' => 'view_invisible_users']])) {
                    unset($output['content'][$i]->online_status);
                }
            }
        }

$option_index = 1;

if (role(['permissions' => ['private_conversations' => 'clear_chat_history']])) {
            $output['options'][$i][$option_index] = new stdClass();
            $output['options'][$i][$option_index]->option = Registry::load('strings')->clear_chat;
            $output['options'][$i][$option_index]->class = 'ask_confirmation';
            $output['options'][$i][$option_index]->attributes['data-remove'] = 'private_chat_messages';
            $output['options'][$i][$option_index]->attributes['data-user_id'] = $user_id;
            $output['options'][$i][$option_index]->attributes['data-clear_chat_history'] = true;
            $output['options'][$i][$option_index]->attributes['confirmation'] = Registry::load('strings')->confirm_action;
            $output['options'][$i][$option_index]->attributes['submit_button'] = Registry::load('strings')->yes;
            $output['options'][$i][$option_index]->attributes['cancel_button'] = Registry::load('strings')->no;
            $option_index++;
        }

if (role(['permissions' => ['private_conversations' => 'export_chat']])) {
            $output['options'][$i][$option_index] = new stdClass();
            $output['options'][$i][$option_index]->option = Registry::load('strings')->export_chat;
            $output['options'][$i][$option_index]->class = 'download_file';
            $output['options'][$i][$option_index]->attributes['download'] = 'messages';
            $output['options'][$i][$option_index]->attributes['data-private_conversation_id'] = $conversation['private_conversation_id'];
            $option_index++;
        }

if (role(['permissions' => ['site_users' => 'block_users']])) {
            if (!isset($conversation['user_blocked']) || empty($conversation['user_blocked'])) {
                $output['options'][$i][$option_index] = new stdClass();
                $output['options'][$i][$option_index]->option = Registry::load('strings')->block_user;
                $output['options'][$i][$option_index]->class = 'ask_confirmation';
                $output['options'][$i][$option_index]->attributes['data-update'] = 'site_user_blacklist';
                $output['options'][$i][$option_index]->attributes['data-block_user_id'] = $user_id;
                $output['options'][$i][$option_index]->attributes['confirmation'] = Registry::load('strings')->block_user_confirmation;
                $output['options'][$i][$option_index]->attributes['submit_button'] = Registry::load('strings')->yes;
                $output['options'][$i][$option_index]->attributes['cancel_button'] = Registry::load('strings')->no;
                $option_index++;
            } else {
                $output['options'][$i][$option_index] = new stdClass();
                $output['options'][$i][$option_index]->option = Registry::load('strings')->unblock_user;
                $output['options'][$i][$option_index]->class = 'ask_confirmation';
                $output['options'][$i][$option_index]->attributes['data-update'] = 'site_user_blacklist';
                $output['options'][$i][$option_index]->attributes['data-unblock_user_id'] = $user_id;
                $output['options'][$i][$option_index]->attributes['confirmation'] = Registry::load('strings')->unblock_user_confirmation;
                $output['options'][$i][$option_index]->attributes['submit_button'] = Registry::load('strings')->yes;
                $output['options'][$i][$option_index]->attributes['cancel_button'] = Registry::load('strings')->no;
                $option_index++;
            }
        }

if (role(['permissions' => ['site_users' => 'ignore_users']])) {
            if (!isset($conversation['user_ignored']) || empty($conversation['user_ignored'])) {
                $output['options'][$i][$option_index] = new stdClass();
                $output['options'][$i][$option_index]->option = Registry::load('strings')->ignore_user;
                $output['options'][$i][$option_index]->class = 'ask_confirmation';
                $output['options'][$i][$option_index]->attributes['data-update'] = 'site_user_blacklist';
                $output['options'][$i][$option_index]->attributes['data-ignore_user_id'] = $user_id;
                $output['options'][$i][$option_index]->attributes['confirmation'] = Registry::load('strings')->ignore_user_confirmation;
                $output['options'][$i][$option_index]->attributes['submit_button'] = Registry::load('strings')->yes;
                $output['options'][$i][$option_index]->attributes['cancel_button'] = Registry::load('strings')->no;
                $option_index++;
            } else {
                $output['options'][$i][$option_index] = new stdClass();
                $output['options'][$i][$option_index]->option = Registry::load('strings')->unignore_user;
                $output['options'][$i][$option_index]->class = 'ask_confirmation';
                $output['options'][$i][$option_index]->attributes['data-update'] = 'site_user_blacklist';
                $output['options'][$i][$option_index]->attributes['data-unignore_user_id'] = $user_id;
                $output['options'][$i][$option_index]->attributes['confirmation'] = Registry::load('strings')->unignore_user_confirmation;
                $output['options'][$i][$option_index]->attributes['submit_button'] = Registry::load('strings')->yes;
                $output['options'][$i][$option_index]->attributes['cancel_button'] = Registry::load('strings')->no;
                $option_index++;
            }
        }

if (role(['permissions' => ['private_conversations' => 'super_privileges']])) {
            $output['options'][$i][$option_index] = new stdClass();
            $output['options'][$i][$option_index]->option = Registry::load('strings')->delete;
            $output['options'][$i][$option_index]->class = 'ask_confirmation';
            $output['options'][$i][$option_index]->attributes['data-remove'] = 'private_conversations';
            $output['options'][$i][$option_index]->attributes['data-private_conversation_id'] = $conversation['private_conversation_id'];
            $output['options'][$i][$option_index]->attributes['confirmation'] = Registry::load('strings')->confirm_action;
            $output['options'][$i][$option_index]->attributes['submit_button'] = Registry::load('strings')->yes;
            $output['options'][$i][$option_index]->attributes['cancel_button'] = Registry::load('strings')->no;
            $option_index++;
        }

$output['options'][$i][$option_index] = new stdClass();
        $output['options'][$i][$option_index]->option = Registry::load('strings')->profile;
        $output['options'][$i][$option_index]->class = 'get_info force_request';
        $output['options'][$i][$option_index]->attributes['user_id'] = $user_id;
        $option_index++;

$i++;
    }
}
?>