用户体系接口的完成

link · link · commit 7129f8b3ef6a · 2016-12-06T17:31:22.000+08:00
diff --git a/src/EasemobServiceProvider.php b/src/EasemobServiceProvider.php
@@ -2,6 +2,8 @@
 
 use Illuminate\Support\ServiceProvider;
 
+use link1st\Easemob\App\Easemob;
+
 class EasemobServiceProvider extends ServiceProvider {
 
 	/**
diff --git a/src/app/Easemob.php b/src/app/Easemob.php
@@ -1,5 +1,5 @@
 <?php
-namespace link1st\Easemob;
+namespace link1st\Easemob\App;
 
 use Config;
 use Cache;
@@ -28,6 +28,9 @@ class Easemob
     // token缓存时间
     public $token_cache_time = null;
 
+    // url地址
+    public $url = null;
+
 
     public function __construct()
     {
@@ -37,53 +40,253 @@ public function __construct()
         $this->client_id        = Config::get('easemob.client_id');
         $this->client_secret    = Config::get('easemob.client_secret');
         $this->token_cache_time = Config::get('easemob.token_cache_time');
+        $this->url              = sprintf('%s/%s/%s/', $this->domain_name, $this->org_name, $this->app_name);
     }
 
+    /***********************   注册   **********************************/
 
     /**
-     * 获取配置项
-     * @return int
+     * 开放注册用户
+     *
+     * @param        $name      [用户名]
+     * @param string $password  [密码]
+     * @param string $nick_name [昵称]
+     *
+     * @return mixed
      */
-    function get_config()
+    public function publicRegistration($name, $password = '', $nick_name = "")
     {
-        return Config::get('easemob.EASEMOB_DOMAIN', "空");
+        $url    = $this->url.'users';
+        $option = [
+            'username' => $name,
+            'password' => $password,
+            'nickname' => $nick_name,
+        ];
+
+        return Http::postCurl($url, $option, 0);
     }
 
 
     /**
-     * 默认
+     * 授权注册用户
+     *
+     * @param        $name      [用户名]
+     * @param string $password  [密码]
+     * @param string $nick_name [昵称]
+     *
      * @return mixed
      */
-    public function index()
+    public function authorizationRegistration($name, $password = '123456')
     {
-        return 'index';
+        $url          = $this->url.'users';
+        $option       = [
+            'username' => $name,
+            'password' => $password,
+        ];
+        $access_token = $this->getToken();
+        $header []    = 'Authorization: Bearer '.$access_token;
+
+        return Http::postCurl($url, $option, $header);
     }
 
 
-    public function getToken()
+    /**
+     * 授权注册用户——批量
+     * 密码不为空
+     *
+     * @param    array $users [用户名 包含 username,password的数组]
+     *
+     * @return mixed
+     */
+    public function authorizationRegistrations($users)
     {
-        $url    = $this->domain_name."/easemob-demo/chatdemoui/token";
-        $option = [
-            'grant_type'    => 'client_credentials',
-            'client_id'     => $this->client_id,
-            'client_secret' => $this->client_secret,
+        $url          = $this->url.'users';
+        $option       = $users;
+        $access_token = $this->getToken();
+        $header []    = 'Authorization: Bearer '.$access_token;
+
+        return Http::postCurl($url, $option, $header);
+    }
+
+    /***********************   用户操作   **********************************/
+
+    /**
+     * 获取单个用户
+     *
+     * @param $user_name
+     *
+     * @return mixed
+     */
+    public function getUser($user_name)
+    {
+        $url          = $this->url.'users/'.$user_name;
+        $option       = [];
+        $access_token = $this->getToken();
+        $header []    = 'Authorization: Bearer '.$access_token;
+
+        return Http::postCurl($url, $option, $header, 'GET');
+    }
+
+
+    /**
+     * 获取所有用户
+     *
+     * @param int    $limit  [显示条数]
+     * @param string $cursor [光标，在此之后的数据]
+     *
+     * @return mixed
+     */
+    public function getUserAll($limit = 10, $cursor = '')
+    {
+        $url          = $this->url.'users';
+        $option       = [
+            'limit'  => $limit,
+            'cursor' => $cursor
+        ];
+        $access_token = $this->getToken();
+        $header []    = 'Authorization: Bearer '.$access_token;
+
+        return Http::postCurl($url, $option, $header, 'GET');
+    }
+
+
+    /**
+     * 删除用户
+     * 删除一个用户会删除以该用户为群主的所有群组和聊天室
+     *
+     * @param $user_name
+     *
+     * @return mixed
+     */
+    public function delUser($user_name)
+    {
+        $url          = $this->url.'users/'.$user_name;
+        $option       = [];
+        $access_token = $this->getToken();
+        $header []    = 'Authorization: Bearer '.$access_token;
+
+        return Http::postCurl($url, $option, $header, 'DELETE');
+    }
+
+
+    /**
+     * 修改密码
+     *
+     * @param $user_name
+     * @param $new_password [新密码]
+     *
+     * @return mixed
+     */
+    public function editUserPassword($user_name, $new_password)
+    {
+        $url          = $this->url.'users/'.$user_name.'/password';
+        $option       = [
+            'newpassword' => $password
+        ];
+        $access_token = $this->getToken();
+        $header []    = 'Authorization: Bearer '.$access_token;
+
+        return Http::postCurl($url, $option, $header, 'PUT');
+    }
+
+
+    /**
+     * 修改用户昵称
+     * 只能在后台看到，前端无法看见这个昵称
+     *
+     * @param $user_name
+     * @param $nickname
+     *
+     * @return mixed
+     */
+    public function editUserNickName($user_name, $nickname)
+    {
+        $url          = $this->url.'users/'.$user_name;
+        $option       = [
+            'nickname' => $nickname
         ];
-        $return = Http::postCurl($url,$option);
-        dump($return);
-        return $return->access_token;
-        //// 获取token
-        //$token = Cache::remember(self::CACHE_NAME, $this->token_cache_time, function () {
-        //    $url    = $this->domain_name."/easemob-demo/chatdemoui/token";
-        //    $option = [
-        //        'grant_type'    => 'client_credentials',
-        //        'client_id'     => $this->client_id,
-        //        'client_secret' => $this->client_secret,
-        //    ];
-        //    $return = Http::postCurl($url,$option);
-        //    dump($return);
-        //    return $return->access_token;
-        //});
+        $access_token = $this->getToken();
+        $header []    = 'Authorization: Bearer '.$access_token;
+
+        return Http::postCurl($url, $option, $header, 'PUT');
+    }
+
+
+    /***********************   好友操作   **********************************/
+
+    /**
+     * 给用户添加好友
+     * @param $owner_username [主人]
+     * @param $friend_username [朋友]
+     *
+     * @return mixed
+     */
+    public function addFriend($owner_username, $friend_username)
+    {
+        $url          = $this->url.'users/'.$owner_username.'/contacts/users/'.$friend_username;
+        $option       = [];
+        $access_token = $this->getToken();
+        $header []    = 'Authorization: Bearer '.$access_token;
+
+        return Http::postCurl($url, $option, $header, 'POST');
+    }
+
+    /**
+     * 给用户删除好友
+     * @param $owner_username [主人]
+     * @param $friend_username [朋友]
+     *
+     * @return mixed
+     */
+    public function delFriend($owner_username, $friend_username)
+    {
+        $url          = $this->url.'users/'.$owner_username.'/contacts/users/'.$friend_username;
+        $option       = [];
+        $access_token = $this->getToken();
+        $header []    = 'Authorization: Bearer '.$access_token;
+
+        return Http::postCurl($url, $option, $header, 'DELETE');
+    }
+
+    /**
+     * 查看用户所以好友
+     * @param $user_name
+     *
+     * @return mixed
+     */
+    public function showFriends($user_name){
+        $url          = $this->url.'users/'.$user_name.'/contacts/users/';
+        $option       = [];
+        $access_token = $this->getToken();
+        $header []    = 'Authorization: Bearer '.$access_token;
+        return Http::postCurl($url, $option, $header, 'GET');
+    }
+
+
+    /***********************   token操作   **********************************/
+
+    /**
+     * 返回token
+     *
+     * @return mixed
+     */
+    public function getToken()
+    {
+        if (Cache::has(self::CACHE_NAME)) {
+            return Cache::get(self::CACHE_NAME);
+        } else {
+            $url    = $this->url."token";
+            $option = [
+                'grant_type'    => 'client_credentials',
+                'client_id'     => $this->client_id,
+                'client_secret' => $this->client_secret,
+            ];
+            $return = Http::postCurl($url, $option);
+            Cache::put(self::CACHE_NAME, $return['access_token'], (int) ($return['expires_in'] / 60));
+
+            return $return['access_token'];
 
+        }
     }
 
 }
diff --git a/src/app/EasemobError.php b/src/app/EasemobError.php
@@ -5,7 +5,7 @@
  * Date: 2016/12/6
  * Time: 15:43
  */
-namespace link1st\Easemob;
+namespace link1st\Easemob\App;
 
 class EasemobError extends \Exception
 {
diff --git a/src/app/ErrorMessage.php b/src/app/ErrorMessage.php
@@ -1,5 +1,5 @@
 <?php
-
+namespace link1st\Easemob\App;
 /**
  * Created by PhpStorm.
  * User: link
diff --git a/src/app/Http.php b/src/app/Http.php
@@ -5,7 +5,7 @@
  * Date: 2016/12/6
  * Time: 14:56
  */
-namespace link1st\Easemob;
+namespace link1st\Easemob\App;
 
 use Cache;
 
@@ -16,18 +16,33 @@
  */
 class Http
 {
+
+    /**
+     * http请求
+     *
+     * @param        $url
+     * @param        $option
+     * @param int    $header
+     * @param string $type
+     * @param int    $setopt
+     *
+     * @return mixed
+     * @throws EasemobError
+     */
     public static function postCurl($url, $option, $header = 0, $type = 'POST',$setopt = 10) {
         $curl = curl_init (); // 启动一个CURL会话
+        if (! empty ( $option )) {
+            if($type == "GET" ){
+                $url .= '?'.http_build_query($option);
+            }else{
+                $options = json_encode ( $option );
+                curl_setopt ( $curl, CURLOPT_POSTFIELDS, $options ); // Post提交的数据包
+            }
+        }
         curl_setopt ( $curl, CURLOPT_URL, $url ); // 要访问的地址
         curl_setopt ( $curl, CURLOPT_SSL_VERIFYPEER, FALSE ); // 对认证证书来源的检查
         curl_setopt ( $curl, CURLOPT_SSL_VERIFYHOST, FALSE ); // 从证书中检查SSL加密算法是否存在
         curl_setopt ( $curl, CURLOPT_USERAGENT, 'Mozilla/4.0 (compatible; MSIE 8.0; Windows NT 6.0; Trident/4.0)' ); // 模拟用户使用的浏览器
-        if (! empty ( $option )) {
-            $options = json_encode ( $option );
-            curl_setopt ( $curl, CURLOPT_POSTFIELDS, $options ); // Post提交的数据包
-        }else{
-            $options = "";
-        }
         curl_setopt ( $curl, CURLOPT_TIMEOUT, $setopt ); // 设置超时限制防止死循环
         if(empty($header)){
             $header = array();
@@ -43,6 +58,22 @@ public static function postCurl($url, $option, $header = 0, $type = 'POST',$seto
             Cache::pull(Easemob::CACHE_NAME);
         }
 
-        return $result;
+        if($status !== 200){
+            $return_array = json_decode($result,true);
+            if($return_array){
+                $error_message = '请求错误:' ;
+                if(isset($return_array['error']))
+                    $error_message .= $return_array['error'];
+                if(isset($return_array['error_description']))
+                    $error_message .= ' '.$return_array['error_description'];
+            }else{
+                $error_message = '请求错误!' ;
+            }
+            throw new EasemobError($error_message,$status);
+        }
+
+        $result_array = json_decode($result,true);
+
+        return $result_array;
     }
 }

Original file line number	Diff line number	Diff line change
`@@ -5,7 +5,7 @@`
`5`	`5`	`* Date: 2016/12/6`
`6`	`6`	`* Time: 15:43`
`7`	`7`	`*/`
`8`		`-namespace link1st\Easemob;`
	`8`	`+namespace link1st\Easemob\App;`
`9`	`9`
`10`	`10`	`class EasemobError extends \Exception`
`11`	`11`	`{`