You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
531 lines
18 KiB
531 lines
18 KiB
<?php
|
|
namespace Application;
|
|
|
|
use \GatewayWorker\Lib\Gateway;
|
|
use \GatewayWorker\Lib\Context;
|
|
use \Application\RoomStatus;
|
|
use \GatewayWorker\Lib\Db;
|
|
use \Config\Site;
|
|
use \Application\Asset\AI;
|
|
|
|
class AdminClient
|
|
{
|
|
|
|
/**
|
|
* 发言频率
|
|
*/
|
|
protected static $frequency = array(
|
|
//等级，发言字数，发言频率(秒)
|
|
// adminer,sysAdminer 80, 1
|
|
// owner 无限制
|
|
0=>array('length'=>15,'time'=>10),
|
|
1=>array('length'=>50,'time'=>8),
|
|
2=>array('length'=>50,'time'=>5),
|
|
3=>array('length'=>50,'time'=>5),
|
|
4=>array('length'=>50,'time'=>3),
|
|
5=>array('length'=>50,'time'=>3),
|
|
6=>array('length'=>50,'time'=>3),
|
|
7=>array('length'=>50,'time'=>3),
|
|
8=>array('length'=>50,'time'=>3),
|
|
9=>array('length'=>50,'time'=>3),
|
|
10=>array('length'=>50,'time'=>3),
|
|
11=>array('length'=>80,'time'=>1),
|
|
12=>array('length'=>80,'time'=>1),
|
|
13=>array('length'=>80,'time'=>1),
|
|
14=>array('length'=>80,'time'=>1),
|
|
15=>array('length'=>80,'time'=>1),
|
|
16=>array('length'=>80,'time'=>1),
|
|
17=>array('length'=>80,'time'=>1),
|
|
18=>array('length'=>80,'time'=>1),
|
|
19=>array('length'=>80,'time'=>1),
|
|
20=>array('length'=>80,'time'=>1),
|
|
21=>array('length'=>80,'time'=>1),
|
|
22=>array('length'=>80,'time'=>1),
|
|
23=>array('length'=>80,'time'=>1),
|
|
24=>array('length'=>80,'time'=>1),
|
|
25=>array('length'=>80,'time'=>1),
|
|
26=>array('length'=>80,'time'=>1),
|
|
27=>array('length'=>80,'time'=>1),
|
|
28=>array('length'=>80,'time'=>1),
|
|
29=>array('length'=>80,'time'=>1),
|
|
//房主/管理
|
|
100=>array('length'=>80,'time'=>1)
|
|
);
|
|
/**
|
|
* 添加系统管理员
|
|
*/
|
|
public static function addSysAdminer($room_id, $user_id)
|
|
{
|
|
$_SESSION['role'] = 'sysAdminer';
|
|
RoomStatus::addSysAdminer($user_id);
|
|
Gateway::sendToGroup($room_id, json_encode(array('type'=>'right.adminer', 'user_id'=>$user_id,'vip'=>$_SESSION['vip'],'levelid'=>$_SESSION['levelid'])));
|
|
}
|
|
|
|
/**
|
|
* 删除系统管理员
|
|
*/
|
|
public static function removeSysAdminer($room_id, $user_id)
|
|
{
|
|
if (isset($_SESSION['role']) && strcmp('sysAdminer', $_SESSION['role']) === 0) {
|
|
unset($_SESSION['role']);
|
|
RoomStatus::removeSysAdminer($user_id);
|
|
Gateway::sendToGroup($room_id, json_encode(array('type'=>'right.removeAdminer', 'user_id'=>$user_id,'vip'=>$_SESSION['vip'],'levelid'=>$_SESSION['levelid'])));
|
|
}
|
|
}
|
|
/**
|
|
* 添加管理员
|
|
*/
|
|
public static function adminer($room_id, $managed_user_id, $managed_client_id_array, $managed_client_name, $self = false, $upDb = true)
|
|
{
|
|
if ($upDb) {
|
|
// 写入数据库
|
|
$ret = Db::instance('dbDefault')->query("select id as uid from ss_member where curroomnum={$room_id}");
|
|
if (!empty($ret[0])) {
|
|
$uid = $ret[0]['uid'];
|
|
$time = time();
|
|
$exist = Db::instance('dbDefault')->query("select id from ss_roomadmin where uid='{$uid}' and adminuid='{$managed_user_id}'");
|
|
if (empty($exist)) {
|
|
Db::instance('dbDefault')->query("insert into ss_roomadmin value (null,{$uid},{$managed_user_id},{$time})");
|
|
}
|
|
}
|
|
}
|
|
Gateway::sendToGroup($room_id, json_encode(array('type'=>'right.adminer', 'user_id'=>$managed_user_id,'vip'=>$_SESSION['vip'],'levelid'=>$_SESSION['levelid'])));
|
|
if ($self) {
|
|
$_SESSION['role'] = 'adminer';
|
|
} else {
|
|
$session_for_update = array('role'=>'adminer');
|
|
foreach ($managed_client_id_array as $managed_client_id) {
|
|
\GatewayWorker\Lib\Gateway::updateSession($managed_client_id, $session_for_update);
|
|
}
|
|
}
|
|
return RoomStatus::addAdminer($room_id, $managed_user_id);
|
|
}
|
|
|
|
/**
|
|
* 删除管理员
|
|
*/
|
|
public static function removeAdminer($room_id, $managed_user_id, $managed_client_id_array, $managed_client_name, $self = false, $upDb = true)
|
|
{
|
|
if ($upDb) {
|
|
// 从数据库删除
|
|
$ret = Db::instance('dbDefault')->query("select id as uid from ss_member where curroomnum={$room_id}");
|
|
if (!empty($ret[0])) {
|
|
$uid = $ret[0]['uid'];
|
|
Db::instance('dbDefault')->query("delete from ss_roomadmin where uid={$uid} and adminuid={$managed_user_id}");
|
|
}
|
|
}
|
|
|
|
Gateway::sendToGroup($room_id, json_encode(array('type'=>'right.removeAdminer', 'user_id'=>$managed_user_id,'vip'=>$_SESSION['vip'],'levelid'=>$_SESSION['levelid'])));
|
|
if ($self) {
|
|
unset($_SESSION['role']);
|
|
} else {
|
|
foreach ($managed_client_id_array as $managed_client_id) {
|
|
$session = \GatewayWorker\Lib\Gateway::getSession($managed_client_id);
|
|
if($session) {
|
|
unset($session['role']);
|
|
\GatewayWorker\Lib\Gateway::setSession($managed_client_id, $session);
|
|
}
|
|
}
|
|
}
|
|
return RoomStatus::removeAdminer($room_id, $managed_user_id);
|
|
}
|
|
|
|
public static function addKicked($room_id, $managed_user_id, $managed_client_id_array, $managed_client_name)
|
|
{
|
|
// 踢人,让该用户退出房间，并广播至所有人
|
|
RoomStatus::addKicked($room_id, $managed_user_id, time()+3600);
|
|
foreach( $managed_client_id_array as $managed_client_id) {
|
|
Gateway::sendToClient($managed_client_id, json_encode(array('type'=>'error.kicked','content'=>'您已被踢出房间 1 小时')));
|
|
Gateway::closeClient($managed_client_id);
|
|
}
|
|
|
|
// $new_message = array(
|
|
// "type"=>"error",
|
|
// "kicked_client_id" => $managed_client_id,
|
|
// 'kicked_client_name' => $managed_client_name,
|
|
// "content"=>"$managed_client_name 已被踢出房间",
|
|
// );
|
|
// return Gateway::sendToGroup($room_id, json_encode($new_message));
|
|
}
|
|
|
|
public static function removeKicked($room_id, $managed_user_id, $managed_client_id_array, $managed_client_name)
|
|
{
|
|
return RoomStatus::removeKicked($room_id, $managed_user_id);
|
|
}
|
|
|
|
public static function disableMsg($room_id, $managed_user_id, $managed_client_id_array, $managed_client_name)
|
|
{
|
|
// 禁言，并广播至所有人
|
|
$expire = time() + 300;
|
|
RoomStatus::disableMsg($room_id, $managed_user_id, $expire);
|
|
$session_for_update = array(
|
|
'disableMsg' => true,
|
|
'expire' => $expire
|
|
);
|
|
// Gateway::sendToClient($managed_client_id, json_encode(array("type"=>"error.disableMsg","content"=>"您已被管理员禁言")));
|
|
|
|
foreach ($managed_client_id_array as $managed_client_id) {
|
|
\GatewayWorker\Lib\Gateway::updateSession($managed_client_id, $session_for_update);
|
|
}
|
|
|
|
$new_message = array(
|
|
"type" => "sysmsg",
|
|
"content" => "$managed_client_name 已被管理员禁言5分钟",
|
|
);
|
|
Gateway::sendToGroup($room_id, json_encode($new_message));
|
|
}
|
|
|
|
public static function enableMsg($room_id, $managed_user_id, $managed_client_id_array, $managed_client_name)
|
|
{
|
|
// 允许发言
|
|
RoomStatus::enableMsg($room_id, $managed_user_id);
|
|
|
|
foreach ($managed_client_id_array as $managed_client_id) {
|
|
$session = \GatewayWorker\Lib\Gateway::getSession($managed_client_id);
|
|
if($session){
|
|
unset($session['disableMsg']);
|
|
unset($session['expire']);
|
|
\GatewayWorker\Lib\Gateway::setSession($managed_client_id, $session);
|
|
}
|
|
}
|
|
}
|
|
|
|
/**
|
|
* 判断用户角色
|
|
*/
|
|
public static function getClientRole($room_id, $user_id, &$expire = 0)
|
|
{
|
|
$role = null;
|
|
//TODO 从MEM中获取当前房间信息
|
|
$roomStatus = RoomStatus::getRoomStatus($room_id);
|
|
$sysAdminer = RoomStatus::getSysAdminer();
|
|
if (strcmp($user_id, $roomStatus['owner']) === 0) {
|
|
return 'owner';
|
|
}
|
|
if (in_array($user_id, $sysAdminer)) {
|
|
return 'sysAdminer';
|
|
}
|
|
if (is_null($roomStatus)) {
|
|
return $role;
|
|
}
|
|
/*
|
|
$roomStatus = array(
|
|
'owner' => 0000,
|
|
'adminer' => array(
|
|
790=>790
|
|
),
|
|
'kicked' => array(
|
|
// 790=>1453909804,
|
|
),
|
|
'disableMsg' => array(
|
|
790 => 1453909804,
|
|
),
|
|
);
|
|
*/
|
|
else if (in_array($user_id, $roomStatus['adminer'])) {
|
|
$role = 'adminer';
|
|
} else if (isset($roomStatus['kicked'][$user_id])) {
|
|
$role = 'kicked';
|
|
$expire = $roomStatus['kicked'][$user_id];
|
|
} else if (isset($roomStatus['disableMsg'][$user_id])) {
|
|
$expire = $roomStatus['disableMsg'][$user_id];
|
|
if ($expire >= time()) {
|
|
$role = 'disableMsg';
|
|
}
|
|
}
|
|
|
|
return $role;
|
|
}
|
|
|
|
public static function isEnableMsg()
|
|
{
|
|
if (isset($_SESSION['role']) && strcmp($_SESSION['role'], 'adminer') === 0) {
|
|
return true;
|
|
}
|
|
if (isset($_SESSION['disableMsg'])) {
|
|
if ($_SESSION['expire'] >= time()) {
|
|
// 解禁发言时间未到
|
|
return false;
|
|
} else {
|
|
// 禁言时间已过
|
|
unset($_SESSION['disableMsg']);
|
|
unset($_SESSION['expire']);
|
|
return true;
|
|
}
|
|
}
|
|
return true;
|
|
}
|
|
|
|
/**
|
|
*是否从网页端登录，并且没有被踢出房间
|
|
*/
|
|
public static function isLogged($user_id, $token)
|
|
{
|
|
if (!is_null($token) && !empty($token) && strcmp(RoomStatus::getUserSession($user_id, $token), $token) === 0) {
|
|
return true;
|
|
}
|
|
return false;
|
|
}
|
|
|
|
public static function hasVipPrivilete($user_id)
|
|
{
|
|
$privilete = RoomStatus::getVipStatus($user_id);
|
|
if (is_null($privilete)) {
|
|
return 0;
|
|
}
|
|
if (isset($privilete['vip']) && ($privilete['vip'] == 1 || $privilete['vip'] == 2)) {
|
|
return $privilete['vip'];
|
|
}
|
|
return 0;
|
|
}
|
|
/**
|
|
*是否能管理该用户
|
|
*/
|
|
public static function ableToManage($user_id, $room_id)
|
|
{
|
|
return RoomStatus::ableToManage($user_id, $room_id);
|
|
}
|
|
|
|
/**
|
|
*获取房间管理员
|
|
*/
|
|
public static function getRoomAdminer($room_id)
|
|
{
|
|
$ret = array();
|
|
$roomStatus = RoomStatus::getRoomStatus($room_id);
|
|
$ret['roomAdminer'] = isset($roomStatus['adminer']) ? $roomStatus['adminer'] : array();
|
|
$ret['sysAdminer'] = RoomStatus::getSysAdminer();
|
|
return $ret;
|
|
}
|
|
|
|
public static function checkUserRoleChanged($user_id, $room_id, $role = null)
|
|
{
|
|
if (!empty(RoomStatus::$changedSysStatus)) {
|
|
if (isset(RoomStatus::$changedSysStatus['add'][$user_id])) {
|
|
unset(RoomStatus::$changedSysStatus['add'][$user_id]);
|
|
if (strcmp($role, 'sysAdminer') !== 0) {
|
|
return 'addSysAdminer';
|
|
}
|
|
}
|
|
if (isset(RoomStatus::$changedSysStatus['remove'][$user_id])) {
|
|
unset(RoomStatus::$changedSysStatus['remove'][$user_id]);
|
|
if (strcmp($role, 'sysAdminer') === 0) {
|
|
return 'removeSysAdminer';
|
|
}
|
|
}
|
|
}
|
|
|
|
if (!empty(RoomStatus::$changedRoomStatus) && isset(RoomStatus::$changedRoomStatus[$room_id])) {
|
|
if (isset(RoomStatus::$changedRoomStatus[$room_id]['add'][$user_id])) {
|
|
unset(RoomStatus::$changedRoomStatus[$room_id]['add'][$user_id]);
|
|
if (!$role) {
|
|
return 'adminer';
|
|
}
|
|
}
|
|
if (isset(RoomStatus::$changedRoomStatus[$room_id]['remove'][$user_id])) {
|
|
unset(RoomStatus::$changedRoomStatus[$room_id]['remove'][$user_id]);
|
|
if (strcmp($role, 'adminer') === 0) {
|
|
return 'removeAdminer';
|
|
}
|
|
}
|
|
}
|
|
return null;
|
|
}
|
|
|
|
/**
|
|
* 用户是否在当前房间
|
|
* @param int $user_id
|
|
* @param int $room_id
|
|
* @return bool
|
|
*/
|
|
public static function inCurrentRoom($user_id, $room_id)
|
|
{
|
|
return false;
|
|
$clientList = Gateway::getClientInfoByGroup($room_id);
|
|
foreach($clientList as $client) {
|
|
if (!empty($client) && $client['user_id'] == $user_id) {
|
|
return true;
|
|
}
|
|
}
|
|
return false;
|
|
}
|
|
|
|
/**
|
|
* 是否可以发私信
|
|
*/
|
|
public static function ablePriMsg()
|
|
{
|
|
if (isset($_SESSION['role']) && in_array($_SESSION['role'],array('owner','adminer','sysAdminer'))) {
|
|
return true;
|
|
}
|
|
if ($_SESSION['levelid'] <= 2) {
|
|
return false;
|
|
}
|
|
return true;
|
|
}
|
|
|
|
/**
|
|
* 限制发消息频率
|
|
*/
|
|
public static function msgFrequency($length, &$msg)
|
|
{
|
|
$time = time();
|
|
if (isset($_SESSION['role']) && in_array($_SESSION['role'],array('adminer','sysAdminer','owner'))) {
|
|
$msg = "房主/管理员每" . static::$frequency[100]['time'] . "秒发一次消息，每条消息不得超过" . static::$frequency[100]['length'] . "字";
|
|
if ($_SESSION['msged']) {
|
|
if ($time - $_SESSION['time'] < static::$frequency[100]['time']) {
|
|
return false;
|
|
} else if ($length > static::$frequency[100]['length']) {
|
|
return false;
|
|
}
|
|
$_SESSION['time'] = $time;
|
|
return true;
|
|
} else if ($length > static::$frequency[100]['length']) {
|
|
$_SESSION['msged'] = true;
|
|
return false;
|
|
}
|
|
$_SESSION['msged'] = true;
|
|
return true;
|
|
}
|
|
if (isset(static::$frequency[$_SESSION['levelid']])) {
|
|
$msg = "富豪等级" . $_SESSION['levelid'] . "每" . static::$frequency[$_SESSION['levelid']]['time'] . "秒发一次消息，每条消息不得超过" . static::$frequency[$_SESSION['levelid']]['length'] . "字";
|
|
if ($_SESSION['msged']) {
|
|
if ($time - $_SESSION['time'] < static::$frequency[$_SESSION['levelid']]['time']) {
|
|
return false;
|
|
} else if ($length > static::$frequency[$_SESSION['levelid']]['length']) {
|
|
return false;
|
|
}
|
|
$_SESSION['time'] = $time;
|
|
return true;
|
|
} else if ($length > static::$frequency[$_SESSION['levelid']]['length']) {
|
|
$_SESSION['msged'] = true;
|
|
return false;
|
|
}
|
|
$_SESSION['msged'] = true;
|
|
return true;
|
|
}
|
|
}
|
|
|
|
// 判断房间是否满员
|
|
public static function isRoomFull($room_id)
|
|
{
|
|
return false;
|
|
$status = RoomStatus::getRoomStatus($room_id);
|
|
var_dump($status);
|
|
return $status['maxonline'] == 0;
|
|
}
|
|
|
|
// 获取房间在线在线人数
|
|
public static function getClientNumByRoom($room_id)
|
|
{
|
|
$num = RoomStatus::getClientNum($room_id);
|
|
return !$num ? 0 : $num;
|
|
}
|
|
|
|
public static function getSortedClientByRoom($room_id)
|
|
{
|
|
$sortedClient = RoomStatus::getSortedClient($room_id);
|
|
return is_null($sortedClient) ? array() : $sortedClient;
|
|
}
|
|
|
|
public static function setAnchorOffLine($user_id) {
|
|
return ;
|
|
RoomStatus::updateAnchorOfflineToDb($user_id);
|
|
}
|
|
|
|
public static function setAnchorOnlie($user_id)
|
|
{
|
|
RoomStatus::updateAnchorOnLineToDb($user_id);
|
|
}
|
|
|
|
public static function getAvatar($uid)
|
|
{
|
|
|
|
return "/style/avatar/".substr(md5($uid),0,3)."/{$uid}_small.jpg?t=".time();
|
|
/*
|
|
$base = "/passport/avatar.php?uid={$ucuid}&size=small";
|
|
$hash = self::getFileHash($ucuid);
|
|
return $hash ? $base . "&hash={$hash}" : $base;
|
|
*/
|
|
}
|
|
|
|
/**
|
|
* 获取上传文件路径
|
|
*/
|
|
public static function getUploadPath($uid)
|
|
{
|
|
$uid = abs(intval($uid));
|
|
$uid = sprintf("%09d", $uid);
|
|
$dir1 = substr($uid, 0, 3);
|
|
$dir2 = substr($uid, 3, 2);
|
|
$dir3 = substr($uid, 5, 2);
|
|
return "/passport/data/avatar/".$dir1.'/'.$dir2.'/'.$dir3.'/';
|
|
}
|
|
|
|
public static function getFileHash($uid)
|
|
{
|
|
$path = Site::$host . self::getUploadPath($ucuid) . substr($ucuid, -2) . '_avatar_small.jpg';
|
|
if (@fopen($path, 'r')) {
|
|
return hash_file('md5', $path);
|
|
}
|
|
return '';
|
|
}
|
|
|
|
/**
|
|
* 延迟关闭客户端连接，照顾低配置手机来不及响应问题
|
|
*
|
|
* @param int $time
|
|
* @param string $client_id
|
|
*/
|
|
public static function delayCloseClient($time, $client_id)
|
|
{
|
|
\Workerman\Lib\Timer::add($time,function($client_id) {
|
|
Gateway::closeClient($client_id);
|
|
}, array($client_id), false);
|
|
}
|
|
|
|
/**
|
|
* 发系统消息
|
|
*
|
|
* @param $client_id
|
|
* @param string $lang 语言
|
|
*/
|
|
public static function sendSysMsg($client_id = '', $lang = 'ch')
|
|
{
|
|
$Data = Db::instance('dbDefault')->query("select live_prompt from ss_siteconfig");
|
|
$SysMsg = $Data[0]['live_prompt'];
|
|
if ($SysMsg == '') {
|
|
return ;
|
|
}
|
|
/*
|
|
if (AI::$SysMsg == '') {
|
|
return ;
|
|
}
|
|
|
|
$message = array('type'=>'sysmsg', 'content'=>AI::$SysMsg);*/
|
|
$SysMsg = !isset(AI::$SysMsgAther[$lang]) ? $SysMsg : AI::$SysMsgAther[$lang];
|
|
$message = array('type'=>'sysmsg', 'content'=>$SysMsg);
|
|
if ($client_id == '') {
|
|
Gateway::sendToCurrentClient(json_encode($message));
|
|
return ;
|
|
}
|
|
Gateway::sendToClient($client_id, json_encode($message));
|
|
}
|
|
|
|
public static function filter($content)
|
|
{
|
|
$keyWord = Db::instance('dbDefault')->query("select key_word from ss_keyword");
|
|
$str = $content;
|
|
/*if (!empty(AI::$keyWord)) {
|
|
foreach (AI::$keyWord as $word) {
|
|
$content = str_replace($word, str_repeat("*", strlen($word)), $content);
|
|
}
|
|
}*/
|
|
if (!empty($keyWord)) {
|
|
foreach ($keyWord as $word) {
|
|
$content = str_replace($word['key_word'], str_repeat("*", strlen($word['key_word'])), $content);
|
|
}
|
|
}
|
|
return $content;
|
|
}
|
|
}
|
|
|