添加群组管理员

application/chat/controller/Group.php

@@ -13,6 +13,7 @@ use app\chat\extend\Basic;
 use app\chat\utils\UGroup;
 use app\model\ChatGroup;
 use app\model\ChatGroupMember;
+use phpDocumentor\Reflection\DocBlock\Tags\Return_;
 use think\Db;
 
 class Group extends Basic
@@ -151,14 +152,10 @@ class Group extends Basic
     public function addGroupUserByIds()
     {
         //todo 添加群组成员 1.单个/多个到表中，2.调用环信接口更新进去
-        $chat_group_member=Db::query("SELECT * FROM chat_group_member WHERE unique_id=18112347151 AND group_id=11");
-        var_dump($chat_group_member) ;
-        exit;
-
         $params = $this->params;
-        //        exit;
-        $params['group_users']=["18112347151"];
-        $params['group_id']="39285903392772";
+        //exit;
+        /*$params['group_users']=["18112347151"];
+        $params['group_id']="39285903392772";*/
 
         if (!isset($params['group_id']) and !isset($params['group_users'])) {
             return $this->response("300", "参数不全", ['remote_groupid'=>'']);
@@ -173,20 +170,22 @@ class Group extends Basic
             //var_dump($result) ;
 
             if(isset($result['data']['result']) and $result['data']['result']){
-                $chat_group_group_id=Db::query("SELECT id FROM chat_group WHERE platform_group_id={$group_id}");
+                $Dbreturn=Db::query("SELECT id FROM chat_group WHERE platform_group_id={$group_id}");
+                $chat_group_group_id=$Dbreturn[0]['id'];
+
                 //先查询是否已经存在
                 $chat_group_member=Db::query("SELECT * FROM chat_group_member WHERE unique_id={$v} AND group_id={$chat_group_group_id}");
                 if($chat_group_member){
                     //var_dump($chat_group_group_id) ;
-                    $msgModel = new ChatGroupMember();
-                    $msgModel->where(['unique_id'=>$v,'group_id'=>$chat_group_group_id])
-                        ->update(['is_close' => 1]);
+                    $msgModel   = new ChatGroupMember();
+                    $msgModel   ->where(['unique_id'=>$v,'group_id'=>$chat_group_group_id])
+                                ->update(['is_close' => 0]);
                 }else{
                     //var_dump($chat_group_group_id) ;
                     $msgModel = new ChatGroupMember();
-                    $msgModel->addChatMsgExt([
+                    $msgModel ->addChatMsgExt([
                         'unique_id'  => $v,
-                        'group_id'   => $chat_group_group_id[0]['id'],
+                        'group_id'   => $chat_group_group_id,
                         "type"       => 0 ,
                         "is_close"   => 0]);
                 }
@@ -202,10 +201,9 @@ class Group extends Basic
     {
         //todo 移除群组成员 1.单个或多个跟新到库， 2.调用环信接口更新
         $params = $this->params;
-        //        exit;
-        $params['group_users']=["18112347151"];
-        $params['group_id']="39285903392772";
-
+        //exit;
+        /*$params['group_users']=["18112347151"];
+        $params['group_id']="39285903392772";*/
         if (!isset($params['group_id']) and !isset($params['group_users'])) {
             return $this->response("300", "参数不全", ['remote_groupid'=>'']);
         }
@@ -219,11 +217,13 @@ class Group extends Basic
             //var_dump($result) ;
 
             if(isset($result['data']['result']) and $result['data']['result']){
-                $chat_group_group_id=Db::query("SELECT id FROM chat_group WHERE platform_group_id={$group_id}");
+                $Dbreturn=Db::query("SELECT id FROM chat_group WHERE platform_group_id={$group_id}");
+                $chat_group_group_id=$Dbreturn[0]['id'];
                 //var_dump($chat_group_group_id) ;
-                $msgModel = new ChatGroupMember();
-                $msgModel->where(['unique_id'=>$v,'group_id'=>$chat_group_group_id])
-                    ->update(['is_close' => 1]);
+                $msgModel   = new ChatGroupMember();
+                $msgModel   ->where(['unique_id'=>$v,'group_id'=>$chat_group_group_id])
+                            ->update(['is_close' => 1]);
+
             }
         }
 
@@ -233,9 +233,75 @@ class Group extends Basic
     public function addGroupManage()
     {
         //todo 添加群组管理员 1.单个更新到库， 2.调用环信接口更新
+        $params = $this->params;
+        //exit;
+        $params['group_user']="18112347151";
+        $params['group_id']="39285903392772";
+
+        if (!isset($params['group_id']) and !isset($params['group_user'])) {
+            return $this->response("300", "参数不全", ['remote_groupid'=>'']);
+        }
+        $group_user = $params['group_user'];
+        $group_id = $params['group_id'];
+
+        $UGroup = new UGroup();
+        $result = $UGroup->addGroupManage($group_id,$group_user,$this->accessToken);
+        $result=json_decode($result,true);
+        //var_dump($result) ;
+
+        if(isset($result['data']['result']) and $result['data']['result']=='success'){
+            $Dbreturn=Db::query("SELECT id FROM chat_group WHERE platform_group_id={$group_id}");
+            $chat_group_group_id=$Dbreturn[0]['id'];
+
+            //先查询是否已经存在
+            $chat_group_member=Db::query("SELECT * FROM chat_group_member WHERE unique_id={$group_user} AND group_id={$chat_group_group_id}");
+            if($chat_group_member){
+                //var_dump($chat_group_group_id) ;
+                $msgModel   = new ChatGroupMember();
+                $msgModel   ->where(['unique_id'=>$group_user,'group_id'=>$chat_group_group_id])
+                    ->update(['type' => 1]);
+            }
+            return $this->response("200", "request success");
+        }else{
+            return $this->response("400", "添加失败！");
+        }
+
     }
     public function delGroupManage()
     {
         //todo 移除群组管理员 1.单个更新到库， 2.调用环信接口更新
+        $params = $this->params;
+        //exit;
+        $params['group_user']="18112347151";
+        $params['group_id']="39285903392772";
+
+        if (!isset($params['group_id']) and !isset($params['group_user'])) {
+            return $this->response("300", "参数不全", ['remote_groupid'=>'']);
+        }
+        $group_user = $params['group_user'];
+        $group_id = $params['group_id'];
+
+        $UGroup = new UGroup();
+        $result = $UGroup->delGroupManage($group_id,$group_user,$this->accessToken);
+        $result=json_decode($result,true);
+        //var_dump($result) ;
+
+        if(isset($result['data']['result']) and $result['data']['result']=='success'){
+            $Dbreturn=Db::query("SELECT id FROM chat_group WHERE platform_group_id={$group_id}");
+            $chat_group_group_id=$Dbreturn[0]['id'];
+
+            //先查询是否已经存在
+            $chat_group_member=Db::query("SELECT * FROM chat_group_member WHERE unique_id={$group_user} AND group_id={$chat_group_group_id}");
+            if($chat_group_member){
+                //var_dump($chat_group_group_id) ;
+                $msgModel   = new ChatGroupMember();
+                $msgModel   ->where(['unique_id'=>$group_user,'group_id'=>$chat_group_group_id])
+                    ->update(['type' => 0]);
+            }
+            return $this->response("200", "request success");
+        }else{
+            return $this->response("400", "添加失败！");
+        }
+
     }
 }
\ No newline at end of file

application/chat/utils/UGroup.php

@@ -142,11 +142,66 @@ class UGroup
             "CURLOPT_SSL_VERIFYHOST" => 2,
         ];
         $url           = $this->buildSendUrl().$group_id.'/users/'.$username;
+        $response      = $curl->post($url, $data);
+        Log::record('-------delGroupUserByIds------' . json_encode($response), "info");
+        return $response;
+    }
+    /**
+     * 添加群组管理员
+     * 朱伟 2018年01月29日
+     * @param $group_id
+     * @param $username
+     * @param $access_token
+     * @return CurlResponse|bool
+     */
+    public function addGroupManage($group_id,$username,$access_token)
+    {
+        $arr= array("newadmin"=>$username);
+        $data          = json_encode($arr);
+        $curl          = new \app\chat\utils\CurlUtil();
+        $curl->headers = [
+            "Accept"        => "application/json",
+            "Content-Type"  => "application/json;charset=utf-8",
+            'Authorization' => "Bearer " . $access_token,
+        ];
+        $curl->options = [
+            "CURLOPT_SSL_VERIFYPEER" => 0,
+            "CURLOPT_SSL_VERIFYHOST" => 2,
+        ];
+        //Path: /{org_name}/{app_name}/chatgroups/{group_id}/admin
+        $url           = $this->buildSendUrl().$group_id.'/admin';
+        $response      = $curl->delete($url, $data);
+        Log::record('-------delGroupUserByIds------' . json_encode($response), "info");
+        return $response;
+    }
+    /**
+     * 移除群组管理员
+     * 朱伟 2018年01月29日
+     * @param $group_id
+     * @param $username
+     * @param $access_token
+     * @return CurlResponse|bool
+     */
+    public function delGroupManage($group_id,$username,$access_token)
+    {
+        $arr= array();
+        $data          = json_encode($arr);
+        $curl          = new \app\chat\utils\CurlUtil();
+        $curl->headers = [
+            "Accept"        => "application/json",
+            "Content-Type"  => "application/json;charset=utf-8",
+            'Authorization' => "Bearer " . $access_token,
+        ];
+        $curl->options = [
+            "CURLOPT_SSL_VERIFYPEER" => 0,
+            "CURLOPT_SSL_VERIFYHOST" => 2,
+        ];
+        //
+        $url           = $this->buildSendUrl().$group_id.'/admin/'.$username;
         $response      = $curl->delete($url, $data);
         Log::record('-------delGroupUserByIds------' . json_encode($response), "info");
         return $response;
     }
-
     /**
      * 请求api
      * @return string

application/chat/utils/curl_cookie.txt

 # Netscape HTTP Cookie File
-# http://curl.haxx.se/docs/http-cookies.html
+# https://curl.haxx.se/docs/http-cookies.html
 # This file was generated by libcurl! Edit at your own risk.
 
-a1.easemob.com	FALSE	/	FALSE	1516954583	rememberMe	deleteMe
+a1.easemob.com	FALSE	/	FALSE	1517216688	rememberMe	deleteMe

application/route.php

@@ -149,6 +149,9 @@ Route::group('chat', [
     'delGroup' => [ 'chat/Group/delGroup', [ 'method' => 'post|get' ] ],
     'getGroupUser' => [ 'chat/Group/getGroupUser', [ 'method' => 'post|get' ] ],
     'addGroupUserByIds' => [ 'chat/Group/addGroupUserByIds', [ 'method' => 'post|get' ] ],
+    'delGroupUserByIds' => [ 'chat/Group/delGroupUserByIds', [ 'method' => 'post|get' ] ],
+    'addGroupManage' => [ 'chat/Group/addGroupManage', [ 'method' => 'post|get' ] ],
+    'delGroupManage' => [ 'chat/Group/delGroupManage', [ 'method' => 'post|get' ] ],
 ]);
 
 Route::group('task',[