Skip to content

T
tl_estate
Commit 1fce110f authored by zhuwei's avatar zhuwei Committed by hujun
Browse files
Options

添加群组管理员

parent a498f4d7
Hide whitespace changes
Inline Side-by-side
Showing with 146 additions and 24 deletions
application/chat/controller/Group.php
View file @ 1fce110f
......@@ -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
View file @ 1fce110f
......@@ -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
View file @ 1fce110f
# 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
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment