fastadmin/extend/fast/service/Easemob.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 '';
            }
        }
    }

}