mirror of https://gitee.com/karson/fastadmin.git
308 lines
8.4 KiB
PHP
308 lines
8.4 KiB
PHP
<?php
|
||
|
||
namespace fast\service;
|
||
|
||
use fast\Http;
|
||
use think\Cache;
|
||
use think\Config;
|
||
use think\Log;
|
||
|
||
/**
|
||
* 环信消息类
|
||
*/
|
||
class Easemob
|
||
{
|
||
|
||
const URL = 'https://a1.easemob.com';
|
||
|
||
static $_config = null;
|
||
|
||
/**
|
||
* 创建用户
|
||
*
|
||
* @param string $username 用户名
|
||
* @param string $password 密码
|
||
* @param string $nickname 昵称
|
||
* @param boolean $token 是否认证模式
|
||
* @return array
|
||
*/
|
||
public static function register($username, $password, $nickname = '', $token = TRUE)
|
||
{
|
||
$params = ['username' => $username, 'password' => $password];
|
||
if ($nickname)
|
||
{
|
||
$params['nickname'] = $nickname;
|
||
}
|
||
return self::api('users', $params, $token);
|
||
}
|
||
|
||
/**
|
||
* 创建聊天室
|
||
*
|
||
* @param string $name 名称
|
||
* @param string $description 描述
|
||
* @param string $owner 创建人
|
||
* @param int $maxusers 最多参与者
|
||
* @param array $members 成员
|
||
* @return array
|
||
*/
|
||
public static function createRoom($name, $description, $owner, $maxusers = 5000, $members = [])
|
||
{
|
||
$owner = (string) $owner;
|
||
$params = [
|
||
"name" => $name, //聊天室名称，此属性为必须的
|
||
"description" => $description, //聊天室描述，此属性为必须的
|
||
"maxusers" => $maxusers, //聊天室成员最大数（包括群主），值为数值类型，默认值200，最大值5000，此属性为可选的
|
||
"owner" => $owner, //聊天室的管理员，此属性为必须的
|
||
];
|
||
if ($members)
|
||
{
|
||
if (!in_array($owner, $members))
|
||
{
|
||
$members[] = $owner;
|
||
}
|
||
$params['members'] = $members;
|
||
}
|
||
return self::api('chatrooms', $params, TRUE);
|
||
}
|
||
|
||
/**
|
||
* 创建群组
|
||
*
|
||
* @param string $name 名称
|
||
* @param string $description 描述
|
||
* @param string $owner 管理员
|
||
* @param int $maxusers 最大成员数量
|
||
* @param array $members 成员列表
|
||
* @param boolean $public 是否公开
|
||
* @param boolean $approval 加入是否审核
|
||
* @return array
|
||
*/
|
||
public static function createGroup($name, $description, $owner, $maxusers = 2000, $members = [], $public = TRUE, $approval = FALSE)
|
||
{
|
||
$owner = (string) $owner;
|
||
$params = [
|
||
"groupname" => $name,
|
||
"desc" => $description,
|
||
"public" => (bool) $public,
|
||
"maxusers" => $maxusers,
|
||
"approval" => (bool) $approval,
|
||
"owner" => $owner,
|
||
];
|
||
if ($members)
|
||
{
|
||
if (!in_array($owner, $members))
|
||
{
|
||
$members[] = $owner;
|
||
}
|
||
$params['members'] = $members;
|
||
}
|
||
return self::api('chatgroups', $params, TRUE);
|
||
}
|
||
|
||
/**
|
||
* 修改群组信息
|
||
*
|
||
* @param int $group_id
|
||
* @param string $name
|
||
* @param string $description
|
||
* @param int $maxusers
|
||
* @return array
|
||
*/
|
||
public static function editGroup($group_id, $name, $description, $maxusers)
|
||
{
|
||
$params = [
|
||
"groupname" => $name,
|
||
"desc" => $description,
|
||
"maxusers" => $maxusers,
|
||
];
|
||
return self::api('chatgroups/' . $group_id, $params, TRUE, 'PUT');
|
||
}
|
||
|
||
/**
|
||
* 获取好友列表
|
||
*/
|
||
public static function getFiends($owner_username)
|
||
{
|
||
return self::api("users/{$owner_username}/contacts/users", [], TRUE, 'GET');
|
||
}
|
||
|
||
/**
|
||
* 删除群组
|
||
*
|
||
* @param int $group_id
|
||
* @return array
|
||
*/
|
||
public static function deleteGroup($group_id)
|
||
{
|
||
$params = [];
|
||
return self::api('chatgroups/' . $group_id, $params, TRUE, 'DELETE');
|
||
}
|
||
|
||
/**
|
||
* 发送消息
|
||
*
|
||
* @param string $from 发件人
|
||
* @param string $to 收件人
|
||
* @param mixed $msg 消息内容
|
||
* @param string $target_type 消息类型 users/chatgroups/chatrooms
|
||
* @return array
|
||
*/
|
||
public static function sendMessage($from, $to, $msg, $target_type = 'users')
|
||
{
|
||
if (!is_array($msg))
|
||
{
|
||
$msg = [
|
||
'type' => 'txt',
|
||
'msg' => $msg
|
||
];
|
||
}
|
||
$data = [
|
||
'target_type' => $target_type,
|
||
'target' => is_array($to) ? $to : [$to],
|
||
'from' => $from,
|
||
];
|
||
if (isset($msg['ext']))
|
||
{
|
||
$data['ext'] = $msg['ext'];
|
||
}
|
||
unset($msg['ext']);
|
||
$data['msg'] = $msg;
|
||
return self::api('messages', $data);
|
||
}
|
||
|
||
/**
|
||
* 获取离线消息记录条数
|
||
* @param string $owner_username
|
||
* @return array
|
||
*/
|
||
public static function getOfflineMsgCount($owner_username)
|
||
{
|
||
return self::api("users/{$owner_username}/offline_msg_count", [], TRUE, 'GET');
|
||
}
|
||
|
||
/**
|
||
* 群组添加成员
|
||
* @param int $chatroom_id
|
||
* @param array $usernames
|
||
* @param array
|
||
*/
|
||
public static function addChatRoomMembers($chatroom_id, $usernames)
|
||
{
|
||
return self::api("chatgroups/{$chatroom_id}/users", $usernames, TRUE);
|
||
}
|
||
|
||
/**
|
||
* 添加单个成员POST
|
||
*/
|
||
public static function addOneChatRoomMember($chatroom_id, $username)
|
||
{
|
||
//return $chatroom_id;
|
||
return self::api("chatgroups/{$chatroom_id}/users/{$username}", [], TRUE);
|
||
}
|
||
|
||
/**
|
||
* 群组删除成员
|
||
* @param int $chatroom_id
|
||
* @param string $usernames
|
||
* @return array
|
||
*/
|
||
public static function minusChatRoomMembers($chatroom_id, $usernames)
|
||
{
|
||
return self::api("chatgroups/{$chatroom_id}/users/{$usernames}", [], TRUE, 'DELETE');
|
||
}
|
||
|
||
/**
|
||
* 添加好友
|
||
*/
|
||
public static function addFriends($owner_username, $friend_username)
|
||
{
|
||
return self::api("users/{$owner_username}/contacts/users/{$friend_username}", [], TRUE);
|
||
}
|
||
|
||
/**
|
||
* 删除好友
|
||
*/
|
||
public static function minusFriends($owner_username, $friend_username)
|
||
{
|
||
return self::api("users/{$owner_username}/contacts/users/{$friend_username}", [], TRUE, 'DELETE');
|
||
}
|
||
|
||
/**
|
||
* 查看用户参与的所有群组
|
||
* @param type $owner_username
|
||
* @return type
|
||
*/
|
||
public static function joinedChatgroups($owner_username)
|
||
{
|
||
return self::api("users/{$owner_username}/joined_chatgroups", [], TRUE, 'GET');
|
||
}
|
||
|
||
/**
|
||
* 调用API接口
|
||
*
|
||
* @param string $api 接口
|
||
* @param array $params request head参数
|
||
* @param boolean $token 是否认证模式
|
||
* @param string $method 请求方法 POST/GET
|
||
* @param array $options 扩展配置
|
||
* @return array
|
||
*/
|
||
public static function api($api, $params = [], $token = TRUE, $method = 'POST', $options = [])
|
||
{
|
||
$header = ['Content-Type:application/json'];
|
||
if ($token)
|
||
{
|
||
$header[] = self::getNewToken();
|
||
}
|
||
$config = Config::get('service.easemob');
|
||
$options[CURLOPT_HTTPHEADER] = $header;
|
||
|
||
$url = self::URL . '/' . $config['org_name'] . '/' . $config['app_name'] . '/' . $api;
|
||
//return $url;
|
||
$ret = Http::sendRequest($url, json_encode($params), $method, $options);
|
||
if ($ret['ret'] && $ret['msg'])
|
||
{
|
||
$msg = json_decode($ret['msg'], TRUE);
|
||
if (isset($msg['error']))
|
||
{
|
||
Log::error($ret['msg']);
|
||
}
|
||
return isset($msg['error']) ? [] : $msg;
|
||
}
|
||
else
|
||
{
|
||
return [];
|
||
}
|
||
}
|
||
|
||
private static function getToken()
|
||
{
|
||
$tokendata = Cache::get('easemobtoken');
|
||
if ($tokendata && $tokendata['expiretime'] > time())
|
||
{
|
||
return $tokendata['access_token'];
|
||
}
|
||
else
|
||
{
|
||
$config = Config::get('service.easemob');
|
||
$data = self::api('token', [
|
||
'grant_type' => 'client_credentials',
|
||
'client_id' => $config['client_id'],
|
||
'client_secret' => $config['client_secret'],
|
||
], FALSE, 'POST');
|
||
if ($data)
|
||
{
|
||
$data['expiretime'] = time() + $data['expires_in'];
|
||
Cache::set('easemobtoken', $data, $data['expires_in'] - 10);
|
||
return $data['access_token'];
|
||
}
|
||
else
|
||
{
|
||
return '';
|
||
}
|
||
}
|
||
}
|
||
|
||
}
|