移除群组成员

application/chat/controller/Group.php

@@ -151,11 +151,83 @@ 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";
+
+        if (!isset($params['group_id']) and !isset($params['group_users'])) {
+            return $this->response("300", "参数不全", ['remote_groupid'=>'']);
+        }
+        $group_users = $params['group_users'];
+        $group_id = $params['group_id'];
+
+        $UGroup = new UGroup();
+        foreach ($group_users as $k => $v) {
+            $result = $UGroup->addGroupUserByIds($group_id,$v,$this->accessToken);
+            $result=json_decode($result,true);
+            //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}");
+                //先查询是否已经存在
+                $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]);
+                }else{
+                    //var_dump($chat_group_group_id) ;
+                    $msgModel = new ChatGroupMember();
+                    $msgModel->addChatMsgExt([
+                        'unique_id'  => $v,
+                        'group_id'   => $chat_group_group_id[0]['id'],
+                        "type"       => 0 ,
+                        "is_close"   => 0]);
+                }
+
+            }
+        }
+
+        return $this->response("200", "request success");
+
     }
 
     public function delGroupUserByIds()
     {
         //todo 移除群组成员 1.单个或多个跟新到库， 2.调用环信接口更新
+        $params = $this->params;
+        //        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'=>'']);
+        }
+        $group_users = $params['group_users'];
+        $group_id = $params['group_id'];
+
+        $UGroup = new UGroup();
+        foreach ($group_users as $k => $v) {
+            $result = $UGroup->delGroupUserByIds($group_id,$v,$this->accessToken);
+            $result=json_decode($result,true);
+            //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}");
+                //var_dump($chat_group_group_id) ;
+                $msgModel = new ChatGroupMember();
+                $msgModel->where(['unique_id'=>$v,'group_id'=>$chat_group_group_id])
+                    ->update(['is_close' => 1]);
+            }
+        }
+
+        return $this->response("200", "request success");
     }
 
     public function addGroupManage()

application/chat/utils/UGroup.php

@@ -96,6 +96,56 @@ class UGroup
         Log::record('-------deleteGroup------' . json_encode($response), "info");
         return $response;
     }
+    /** 添加群组成员
+     * 朱伟 2018年01月26日
+     */
+    public function addGroupUserByIds($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.'/users/'.$username;
+        $response      = $curl->post($url, $data);
+        Log::record('-------addGroupUserByIds------' . json_encode($response), "info");
+        return $response;
+    }
+
+    /**
+     * 移除群组成员
+     * 朱伟 2018年01月29日
+     * @param $group_id
+     * @param $username
+     * @param $access_token
+     * @return CurlResponse|bool
+     */
+    public function delGroupUserByIds($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.'/users/'.$username;
+        $response      = $curl->delete($url, $data);
+        Log::record('-------delGroupUserByIds------' . json_encode($response), "info");
+        return $response;
+    }
 
     /**
      * 请求api

application/route.php

@@ -148,6 +148,7 @@ Route::group('chat', [
     'createGroupByOnlyId' => [ 'chat/Group/createGroupByOnlyId', [ 'method' => 'post|get' ] ],
     'delGroup' => [ 'chat/Group/delGroup', [ 'method' => 'post|get' ] ],
     'getGroupUser' => [ 'chat/Group/getGroupUser', [ 'method' => 'post|get' ] ],
+    'addGroupUserByIds' => [ 'chat/Group/addGroupUserByIds', [ 'method' => 'post|get' ] ],
 ]);
 
 Route::group('task',[