devbox
很楠不爱3
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

环信phpDEMO_php 获取环信用户在线状态

作者：很楠不爱3 | 2024-02-17 02:29:41

赞

踩

php 获取环信用户在线状态
  1. <?php
  2. /**
  3. --------------------------------------------------
  4. 环信PHP REST示例代码
  5. --------------------------------------------------
  6. Copyright(c) 2015 环信即时通信云 www.easemob.com
  7. --------------------------------------------------
  8. Author: 神之爱 <fengpei@easemob.com>
  9. --------------------------------------------------
  10. */
  11. class Easemob{
  12. private $client_id; //app的id
  13. private $client_secret; //app的秘钥
  14. private $org_name; //企业id
  15. private $app_name; //应用名称
  16. private $url; //路径
  17. //------------------------------------------------------用户体系 
  18. /**
  19. * 初始化参数
  20. *
  21. * @param array $options   
  22. * @param $options['client_id']     
  23. * @param $options['client_secret'] 
  24. * @param $options['org_name']     
  25. * @param $options['app_name']   
  26. */
  27. public function __construct($options) {
  28.     $this->client_id = isset ( $options ['client_id'] ) ? $options ['client_id'] : '';
  29.     $this->client_secret = isset ( $options ['client_secret'] ) ? $options ['client_secret'] : '';
  30.     $this->org_name = isset ( $options ['org_name'] ) ? $options ['org_name'] : '';
  31.     $this->app_name = isset ( $options ['app_name'] ) ? $options ['app_name'] : '';
  32.     if (! empty ( $this->org_name ) && ! empty ( $this->app_name )) {
  33.     $this->url = 'https://a1.easemob.com/' . $this->org_name . '/' . $this->app_name . '/';
  34.     }
  35. } 
  36. /**
  37. *获取token 
  38. */
  39. function getToken()
  40. {
  41.     $options=array(
  42.         "grant_type"=>"client_credentials",
  43.         "client_id"=>$this->client_id,
  44.         "client_secret"=>$this->client_secret
  45.     );
  46.  
  47.  
  48.     //json_encode()函数，可将PHP数组或对象转成json字符串，使用json_decode()函数，可以将json字符串转换为PHP数组或对象
  49.     $body=json_encode($options);
  50.     //使用 $GLOBALS 替代 global
  51.     $url=$this->url.'token';
  52.     //$url=$base_url.'token';
  53.     $tokenResult = $this->postCurl($url,$body,$header=array());
  54.     //var_dump($tokenResult['expires_in']);
  55.     //return $tokenResult;
  56.     return "Authorization:Bearer ".$tokenResult['access_token'];
  57.  
  58.  
  59. }
  60. /**
  61.  授权注册
  62. */
  63. function createUser($username,$password){
  64.     $url=$this->url.'users';
  65.     $options=array(
  66.         "username"=>$username,
  67.         "password"=>$password
  68.     );
  69.     $body=json_encode($options);
  70.     $header=array($this->getToken());
  71.     $result=$this->postCurl($url,$body,$header);
  72.     return $result;
  73. }
  74. /*
  75. 批量注册用户
  76. */
  77. function createUsers($options){
  78.     $url=$this->url.'users';
  79.  
  80.     $body=json_encode($options);
  81.     $header=array($this->getToken());
  82.     $result=$this->postCurl($url,$body,$header);
  83.     return $result;
  84. }
  85. /*
  86. 重置用户密码
  87. */
  88. function resetPassword($username,$newpassword){
  89.     $url=$this->url.'users/'.$username.'/password';
  90.     $options=array(
  91.         "newpassword"=>$newpassword
  92.     );
  93.     $body=json_encode($options);
  94.         $header=array($this->getToken());
  95.     $result=$this->postCurl($url,$body,$header,"PUT");
  96.     return $result;
  97. }
  98.  
  99. /*
  100. 获取单个用户
  101. */
  102. function getUser($username){
  103.     $url=$this->url.'users/'.$username;
  104.     $header=array($this->getToken());
  105.     $result=$this->postCurl($url,'',$header,"GET");
  106.     return $result;
  107. }
  108. /*
  109. 获取批量用户----不分页
  110. */
  111. function getUsers($limit=0){
  112.     if(!empty($limit)){
  113.         $url=$this->url.'users?limit='.$limit;
  114.     }else{
  115.         $url=$this->url.'users';
  116.     }
  117.     $header=array($this->getToken());
  118.     $result=$this->postCurl($url,'',$header,"GET");
  119.     return $result;
  120. }
  121. /*
  122. 获取批量用户---分页
  123. */
  124. function getUsersForPage($limit=0,$cursor=''){
  125.     $url=$this->url.'users?limit='.$limit.'&cursor='.$cursor;
  126.  
  127.     $header=array($this->getToken());
  128.     $result=$this->postCurl($url,'',$header,"GET");
  129.     if(!empty($result["cursor"])){
  130.         $cursor=$result["cursor"];
  131.         $this->writeCursor("userfile.txt",$cursor);
  132.     }
  133.     //var_dump($GLOBALS['cursor'].'00000000000000');
  134.     return $result;
  135. }
  136.  
  137. //创建文件夹
  138. function mkdirs($dir, $mode = 0777)
  139. {
  140.     if (is_dir($dir) || @mkdir($dir, $mode)) return TRUE;
  141.     if (!mkdirs(dirname($dir), $mode)) return FALSE;
  142.     return @mkdir($dir, $mode);
  143. } 
  144. //写入cursor
  145. function writeCursor($filename,$content){
  146.     //判断文件夹是否存在，不存在的话创建
  147.     if(!file_exists("resource/txtfile")){
  148.         mkdirs("resource/txtfile");
  149.     }
  150.     $myfile=@fopen("resource/txtfile/".$filename,"w+") or die("Unable to open file!");
  151.     @fwrite($myfile,$content);
  152.     fclose($myfile); 
  153. }
  154. //读取cursor
  155. function readCursor($filename){
  156.     //判断文件夹是否存在，不存在的话创建
  157.     if(!file_exists("resource/txtfile")){
  158.         mkdirs("resource/txtfile");
  159.     }
  160.     $file="resource/txtfile/".$filename;
  161.     $fp=fopen($file,"a+");//这里这设置成a+
  162.     if($fp){
  163.         while(!feof($fp)){
  164.         //第二个参数为读取的长度
  165.             $data=fread($fp,1000); 
  166.         } 
  167.         fclose($fp);
  168.     }  
  169.     return $data; 
  170. }
  171. /*
  172. 删除单个用户
  173. */
  174. function deleteUser($username){
  175.     $url=$this->url.'users/'.$username;
  176.     $header=array($this->getToken());
  177.     $result=$this->postCurl($url,'',$header,'DELETE');
  178.     return $result;
  179. }
  180. /*
  181. 删除批量用户
  182. limit:建议在100-500之间，、
  183. 注：具体删除哪些并没有指定, 可以在返回值中查看。
  184. */
  185. function deleteUsers($limit){
  186.     $url=$this->url.'users?limit='.$limit;
  187.     $header=array($this->getToken());
  188.     $result=$this->postCurl($url,'',$header,'DELETE');
  189.     return $result;
  190.  
  191. }
  192. /*
  193. 修改用户昵称
  194. */
  195. function editNickname($username,$nickname){
  196.     $url=$this->url.'users/'.$username;
  197.     $options=array(
  198.         "nickname"=>$nickname
  199.     );
  200.     $body=json_encode($options);
  201.     $header=array($this->getToken());
  202.     $result=$this->postCurl($url,$body,$header,'PUT');
  203.     return $result;
  204. }
  205. /*
  206. 添加好友-
  207. */
  208. function addFriend($username,$friend_name){
  209.     $url=$this->url.'users/'.$username.'/contacts/users/'.$friend_name;
  210.     $header=array($this->getToken(),'Content-Type:application/json');
  211.     $result=$this->postCurl($url,'',$header,'POST');
  212.     return $result; 
  213.  
  214.  
  215. }
  216.  
  217.  
  218. /*
  219. 删除好友
  220. */
  221. function deleteFriend($username,$friend_name){
  222.     $url=$this->url.'users/'.$username.'/contacts/users/'.$friend_name;
  223.     $header=array($this->getToken());
  224.     $result=$this->postCurl($url,'',$header,'DELETE');
  225.     return $result; 
  226.  
  227. }
  228. /*
  229. 查看好友
  230. */
  231. function showFriends($username){
  232.     $url=$this->url.'users/'.$username.'/contacts/users';
  233.     $header=array($this->getToken());
  234.     $result=$this->postCurl($url,'',$header,'GET');
  235.     return $result; 
  236.  
  237. }
  238. /*
  239. 查看用户黑名单
  240. */
  241. function getBlacklist($username){
  242.     $url=$this->url.'users/'.$username.'/blocks/users';
  243.     $header=array($this->getToken());
  244.     $result=$this->postCurl($url,'',$header,'GET');
  245.     return $result;
  246.  
  247. }
  248. /*
  249. 往黑名单中加人
  250. */
  251. function addUserForBlacklist($username,$usernames){
  252.     $url=$this->url.'users/'.$username.'/blocks/users';
  253.     $body=json_encode($usernames);
  254.     $header=array($this->getToken());
  255.     $result=$this->postCurl($url,$body,$header,'POST');
  256.     return $result; 
  257.  
  258. }
  259. /*
  260. 从黑名单中减人
  261. */
  262. function deleteUserFromBlacklist($username,$blocked_name){
  263.     $url=$this->url.'users/'.$username.'/blocks/users/'.$blocked_name;
  264.     $header=array($this->getToken());
  265.     $result=$this->postCurl($url,'',$header,'DELETE');
  266.     return $result; 
  267.  
  268. }
  269. /*
  270. 查看用户是否在线
  271. */
  272. function isOnline($username){
  273.     $url=$this->url.'users/'.$username.'/status';
  274.     $header=array($this->getToken());
  275.     $result=$this->postCurl($url,'',$header,'GET');
  276.     return $result; 
  277.  
  278. }
  279. /*
  280. 查看用户离线消息数
  281. */
  282. function getOfflineMessages($username){
  283.     $url=$this->url.'users/'.$username.'/offline_msg_count';
  284.     $header=array($this->getToken());
  285.     $result=$this->postCurl($url,'',$header,'GET');
  286.     return $result; 
  287.  
  288. }
  289. /*
  290. 查看某条消息的离线状态
  291. ----deliverd 表示此用户的该条离线消息已经收到
  292. */
  293. function getOfflineMessageStatus($username,$msg_id){
  294.     $url=$this->url.'users/'.$username.'/offline_msg_status/'.$msg_id;
  295.     $header=array($this->getToken());
  296.     $result=$this->postCurl($url,'',$header,'GET');
  297.     return $result; 
  298.  
  299. }
  300. /*
  301. 禁用用户账号
  302. */ 
  303. function deactiveUser($username){
  304.     $url=$this->url.'users/'.$username.'/deactivate';
  305.     $header=array($this->getToken());
  306.     $result=$this->postCurl($url,'',$header);
  307.     return $result;
  308. }
  309. /*
  310. 解禁用户账号
  311. */ 
  312. function activeUser($username){
  313.     $url=$this->url.'users/'.$username.'/activate';
  314.     $header=array($this->getToken());
  315.     $result=$this->postCurl($url,'',$header);
  316.     return $result;
  317. } 
  318.  
  319. /*
  320. 强制用户下线
  321. */ 
  322. function disconnectUser($username){
  323.     $url=$this->url.'users/'.$username.'/disconnect';
  324.     $header=array($this->getToken());
  325.     $result=$this->postCurl($url,'',$header,'GET');
  326.     return $result;
  327. }
  328. //--------------------------------------------------------上传下载
  329. /*
  330. 上传图片或文件
  331. */
  332. function uploadFile($filePath){
  333.     $url=$this->url.'chatfiles';
  334.     $file=file_get_contents($filePath);
  335.     $body['file']=$file;
  336.     $header=array('Content-type: multipart/form-data',$this->getToken(),"restrict-access:true");
  337.     $result=$this->postCurl($url,$body,$header,'XXX');
  338.     return $result;
  339.  
  340. }
  341. /*
  342. 下载文件或图片
  343. */
  344. function downloadFile($uuid,$shareSecret,$ext)
  345. {
  346.     $url = $this->url . 'chatfiles/' . $uuid;
  347.     $header = array("share-secret:" . $shareSecret, "Accept:application/octet-stream", $this->getToken(),);
  348.  
  349.  
  350.     if ($ext=="png") {
  351.         $result=$this->postCurl($url,'',$header,'GET');
  352.     }else {
  353.         $result = $this->getFile($url);
  354.     }
  355.     $filename = md5(time().mt_rand(10, 99)).".".$ext; //新图片名称
  356.     if(!file_exists("resource/down")){
  357.         mkdir("resource/down/");
  358.     }
  359.  
  360.  
  361.     $file = @fopen("resource/down/".$filename,"w+");//打开文件准备写入
  362.     @fwrite($file,$result);//写入
  363.     fclose($file);//关闭
  364.     return $filename;
  365.  
  366. }
  367.  
  368.  
  369. function getFile($url){
  370.     set_time_limit(0); // unlimited max execution time
  371.  
  372.  
  373.     $ch = curl_init($url);
  374.     curl_setopt($ch, CURLOPT_TIMEOUT, 600); //max 10 minutes
  375.     curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
  376.     curl_setopt($ch, CURLOPT_HEADER, false);
  377.     $result = curl_exec($ch);
  378.     curl_close($ch);
  379.     return $result;
  380. }
  381. /*
  382. 下载图片缩略图
  383. */
  384. function downloadThumbnail($uuid,$shareSecret){
  385.     $url=$this->url.'chatfiles/'.$uuid;
  386.     $header = array("share-secret:".$shareSecret,"Accept:application/octet-stream",$this->getToken(),"thumbnail:true");
  387.     $result=$this->postCurl($url,'',$header,'GET');
  388.     $filename = md5(time().mt_rand(10, 99))."th.png"; //新图片名称
  389.     if(!file_exists("resource/down")){
  390.         //mkdir("../image/down");
  391.         mkdirs("resource/down/");
  392.     }
  393.  
  394.     $file = @fopen("resource/down/".$filename,"w+");//打开文件准备写入
  395.     @fwrite($file,$result);//写入
  396.     fclose($file);//关闭
  397.     return $filename;
  398. }
  399.  
  400.  
  401.  
  402. //--------------------------------------------------------发送消息
  403. /*
  404. 发送文本消息
  405. */
  406. function sendText($from="admin",$target_type,$target,$content,$ext){
  407.     $url=$this->url.'messages';
  408.     $body['target_type']=$target_type;
  409.     $body['target']=$target;
  410.     $options['type']="txt";
  411.     $options['msg']=$content;
  412.     $body['msg']=$options;
  413.     $body['from']=$from;
  414.     $body['ext']=$ext;
  415.     $b=json_encode($body);
  416.     $header=array($this->getToken());
  417.     $result=$this->postCurl($url,$b,$header);
  418.     return $result;
  419. }
  420. /*
  421. 发送透传消息
  422. */
  423. function sendCmd($from="admin",$target_type,$target,$action,$ext){
  424.     $url=$this->url.'messages';
  425.     $body['target_type']=$target_type;
  426.     $body['target']=$target;
  427.     $options['type']="cmd";
  428.     $options['action']=$action;
  429.     $body['msg']=$options;
  430.     $body['from']=$from;
  431.     $body['ext']=$ext;
  432.     $b=json_encode($body);
  433.     $header=array($this->getToken()); 
  434.     //$b=json_encode($body,true);
  435.     $result=$this->postCurl($url,$b,$header);
  436.     return $result;
  437. }
  438. /*
  439. 发图片消息
  440. */ 
  441. function sendImage($filePath,$from="admin",$target_type,$target,$filename,$ext){
  442.     $result=$this->uploadFile($filePath);
  443.     $uri=$result['uri'];
  444.     $uuid=$result['entities'][0]['uuid'];
  445.     $shareSecret=$result['entities'][0]['share-secret'];
  446.     $url=$this->url.'messages';
  447.     $body['target_type']=$target_type;
  448.     $body['target']=$target;
  449.     $options['type']="img";
  450.     $options['url']=$uri.'/'.$uuid;
  451.     $options['filename']=$filename;
  452.     $options['secret']=$shareSecret;
  453.     $options['size']=array(
  454.         "width"=>480,
  455.         "height"=>720
  456.     );
  457.     $body['msg']=$options;
  458.     $body['from']=$from;
  459.     $body['ext']=$ext;
  460.     $b=json_encode($body);
  461.     $header=array($this->getToken()); 
  462.     //$b=json_encode($body,true);
  463.     $result=$this->postCurl($url,$b,$header);
  464.     return $result;
  465. }
  466. /*
  467. 发语音消息
  468. */
  469. function sendAudio($filePath,$from="admin",$target_type,$target,$filename,$length,$ext){
  470.     $result=$this->uploadFile($filePath);
  471.     $uri=$result['uri'];
  472.     $uuid=$result['entities'][0]['uuid'];
  473.     $shareSecret=$result['entities'][0]['share-secret'];
  474.     $url=$this->url.'messages';
  475.     $body['target_type']=$target_type;
  476.     $body['target']=$target;
  477.     $options['type']="audio";
  478.     $options['url']=$uri.'/'.$uuid;
  479.     $options['filename']=$filename;
  480.     $options['length']=$length;
  481.     $options['secret']=$shareSecret;
  482.     $body['msg']=$options;
  483.     $body['from']=$from;
  484.     $body['ext']=$ext;
  485.     $b=json_encode($body);
  486.     $header=array($this->getToken()); 
  487.     //$b=json_encode($body,true);
  488.     $result=$this->postCurl($url,$b,$header);
  489.     return $result;
  490. }
  491. /*
  492. 发视频消息
  493. */
  494. function sendVedio($filePath,$from="admin",$target_type,$target,$filename,$length,$thumb,$thumb_secret,$ext){
  495.     $result=$this->uploadFile($filePath);
  496.     $uri=$result['uri'];
  497.     $uuid=$result['entities'][0]['uuid'];
  498.     $shareSecret=$result['entities'][0]['share-secret'];
  499.     $url=$this->url.'messages';
  500.     $body['target_type']=$target_type;
  501.     $body['target']=$target;
  502.     $options['type']="video";
  503.     $options['url']=$uri.'/'.$uuid;
  504.     $options['filename']=$filename;
  505.     $options['thumb']=$thumb;
  506.     $options['length']=$length;
  507.     $options['secret']=$shareSecret;
  508.     $options['thumb_secret']=$thumb_secret;
  509.     $body['msg']=$options;
  510.     $body['from']=$from;
  511.     $body['ext']=$ext;
  512.     $b=json_encode($body);
  513.     $header=array($this->getToken()); 
  514.     //$b=json_encode($body,true);
  515.     $result=$this->postCurl($url,$b,$header);
  516.     return $result;
  517. }
  518. /*
  519. 发文件消息
  520. */
  521. function sendFile($filePath,$from="admin",$target_type,$target,$filename,$length,$ext){
  522.     $result=$this->uploadFile($filePath);
  523.     $uri=$result['uri'];
  524.     $uuid=$result['entities'][0]['uuid'];
  525.     $shareSecret=$result['entities'][0]['share-secret'];
  526.     $url=$GLOBALS['base_url'].'messages';
  527.     $body['target_type']=$target_type;
  528.     $body['target']=$target;
  529.     $options['type']="file";
  530.     $options['url']=$uri.'/'.$uuid;
  531.     $options['filename']=$filename;
  532.     $options['length']=$length;
  533.     $options['secret']=$shareSecret;
  534.     $body['msg']=$options;
  535.     $body['from']=$from;
  536.     $body['ext']=$ext;
  537.     $b=json_encode($body);
  538.     $header=array(getToken()); 
  539.     //$b=json_encode($body,true);
  540.     $result=postCurl($url,$b,$header);
  541.     return $result;
  542. }
  543. //-------------------------------------------------------------群组操作
  544.  
  545. /*
  546. 获取app中的所有群组----不分页
  547. */
  548. function getGroups($limit=0){
  549.     if(!empty($limit)){
  550.         $url=$this->url.'chatgroups?limit='.$limit;
  551.     }else{
  552.         $url=$this->url.'chatgroups';
  553.     }
  554.  
  555.     $header=array($this->getToken());
  556.     $result=$this->postCurl($url,'',$header,"GET");
  557.     return $result;
  558. }
  559. /*
  560. 获取app中的所有群组---分页
  561. */
  562. function getGroupsForPage($limit=0,$cursor=''){
  563.     $url=$this->url.'chatgroups?limit='.$limit.'&cursor='.$cursor;
  564.     $header=array($this->getToken());
  565.         $result=$this->postCurl($url,'',$header,"GET");
  566.  
  567.     if(!empty($result["cursor"])){
  568.         $cursor=$result["cursor"];
  569.         $this->writeCursor("groupfile.txt",$cursor);
  570.     }
  571.     //var_dump($GLOBALS['cursor'].'00000000000000');
  572.     return $result;
  573. }
  574. /*
  575. 获取一个或多个群组的详情
  576. */
  577. function getGroupDetail($group_ids){
  578.     $g_ids=implode(',',$group_ids);
  579.     $url=$this->url.'chatgroups/'.$g_ids;
  580.     $header=array($this->getToken());
  581.     $result=$this->postCurl($url,'',$header,'GET');
  582.     return $result;
  583. }
  584. /*
  585. 创建一个群组
  586. */
  587. function createGroup($options){
  588.     $url=$this->url.'chatgroups';
  589.     $header=array($this->getToken());
  590.     $body=json_encode($options);
  591.     $result=$this->postCurl($url,$body,$header);
  592.     return $result;
  593. }
  594. /*
  595. 修改群组信息
  596. */
  597. function modifyGroupInfo($group_id,$options){
  598.     $url=$this->url.'chatgroups/'.$group_id;
  599.     $body=json_encode($options);
  600.     $header=array($this->getToken());
  601.     $result=$this->postCurl($url,$body,$header,'PUT');
  602.     return $result; 
  603. }
  604. /*
  605. 删除群组
  606. */
  607. function deleteGroup($group_id){
  608.     $url=$this->url.'chatgroups/'.$group_id;
  609.     $header=array($this->getToken());
  610.     $result=$this->postCurl($url,'',$header,'DELETE');
  611.     return $result;
  612. }
  613. /*
  614. 获取群组中的成员
  615. */
  616. function getGroupUsers($group_id){
  617.     $url=$this->url.'chatgroups/'.$group_id.'/users'; 
  618.     $header=array($this->getToken());
  619.     $result=$this->postCurl($url,'',$header,'GET');
  620.     return $result;
  621. }
  622. /*
  623. 群组单个加人
  624. */
  625. function addGroupMember($group_id,$username){
  626.     $url=$this->url.'chatgroups/'.$group_id.'/users/'.$username;
  627.     $header=array($this->getToken(),'Content-Type:application/json');
  628.     $result=$this->postCurl($url,'',$header);
  629.     return $result;
  630. }
  631. /*
  632. 群组批量加人
  633. */
  634. function addGroupMembers($group_id,$usernames){
  635.     $url=$this->url.'chatgroups/'.$group_id.'/users';
  636.     $body=json_encode($usernames);
  637.     $header=array($this->getToken(),'Content-Type:application/json');
  638.     $result=$this->postCurl($url,$body,$header);
  639.     return $result;
  640. }
  641. /*
  642. 群组单个减人
  643. */
  644. function deleteGroupMember($group_id,$username){
  645.     $url=$this->url.'chatgroups/'.$group_id.'/users/'.$username;
  646.     $header=array($this->getToken());
  647.     $result=$this->postCurl($url,'',$header,'DELETE');
  648.     return $result;
  649. }
  650. /*
  651. 群组批量减人
  652. */
  653. function deleteGroupMembers($group_id,$usernames){
  654.     $url=$this->url.'chatgroups/'.$group_id.'/users/'.$usernames;
  655.     //$body=json_encode($usernames);
  656.     $header=array($this->getToken());
  657.     $result=$this->postCurl($url,'',$header,'DELETE');
  658.     return $result;
  659. }
  660. /*
  661. 获取一个用户参与的所有群组
  662. */
  663. function getGroupsForUser($username){
  664.     $url=$this->url.'users/'.$username.'/joined_chatgroups';
  665.     $header=array($this->getToken());
  666.     $result=$this->postCurl($url,'',$header,'GET');
  667.     return $result;
  668. }
  669. /*
  670. 群组转让
  671. */
  672. function changeGroupOwner($group_id,$options){
  673.     $url=$this->url.'chatgroups/'.$group_id;
  674.     $body=json_encode($options);
  675.     $header=array($this->getToken());
  676.     $result=$this->postCurl($url,$body,$header,'PUT');
  677.     return $result;
  678. }
  679. /*
  680. 查询一个群组黑名单用户名列表
  681. */
  682. function getGroupBlackList($group_id){
  683.     $url=$this->url.'chatgroups/'.$group_id.'/blocks/users';
  684.     $header=array($this->getToken());
  685.     $result=$this->postCurl($url,'',$header,'GET');
  686.     return $result;
  687. }
  688. /*
  689. 群组黑名单单个加人
  690. */
  691. function addGroupBlackMember($group_id,$username){
  692.     $url=$this->url.'chatgroups/'.$group_id.'/blocks/users/'.$username;
  693.     $header=array($this->getToken());
  694.     $result=$this->postCurl($url,'',$header);
  695.     return $result;
  696. }
  697. /*
  698. 群组黑名单批量加人
  699. */
  700. function addGroupBlackMembers($group_id,$usernames){
  701.     $url=$this->url.'chatgroups/'.$group_id.'/blocks/users';
  702.     $body=json_encode($usernames);
  703.     $header=array($this->getToken());
  704.     $result=$this->postCurl($url,$body,$header);
  705.     return $result;
  706. }
  707. /*
  708. 群组黑名单单个减人
  709. */
  710. function deleteGroupBlackMember($group_id,$username){
  711.     $url=$this->url.'chatgroups/'.$group_id.'/blocks/users/'.$username;
  712.         $header=array($this->getToken());
  713.     $result=$this->postCurl($url,'',$header,'DELETE');
  714.     return $result;
  715. }
  716. /*
  717. 群组黑名单批量减人
  718. */
  719. function deleteGroupBlackMembers($group_id,$usernames){
  720.     $url=$this->url.'chatgroups/'.$group_id.'/blocks/users';
  721.     $body=json_encode($usernames);
  722.     $header=array($this->getToken());
  723.     $result=$this->postCurl($url,$body,$header,'DELETE');
  724.     return $result;
  725. }
  726. //-------------------------------------------------------------聊天室操作
  727. /*
  728. 创建聊天室
  729. */
  730. function createChatRoom($options){
  731.     $url=$this->url.'chatrooms';
  732.     $header=array($this->getToken());
  733.     $body=json_encode($options);
  734.     $result=$this->postCurl($url,$body,$header);
  735.     return $result;
  736. }
  737. /*
  738. 修改聊天室信息
  739. */
  740. function modifyChatRoom($chatroom_id,$options){
  741.     $url=$this->url.'chatrooms/'.$chatroom_id;
  742.     $body=json_encode($options);
  743.     $result=$this->postCurl($url,$body,$header,'PUT');
  744.     return $result; 
  745. }
  746. /*
  747. 删除聊天室
  748. */
  749. function deleteChatRoom($chatroom_id){
  750.     $url=$this->url.'chatrooms/'.$chatroom_id;
  751.     $header=array($this->getToken());
  752.     $result=$this->postCurl($url,'',$header,'DELETE');
  753.     return $result;
  754. }
  755. /*
  756. 获取app中所有的聊天室
  757. */
  758. function getChatRooms(){
  759.     $url=$this->url.'chatrooms';
  760.     $header=array($this->getToken());
  761.     $result=$this->postCurl($url,'',$header,"GET");
  762.     return $result;
  763. }
  764.  
  765. /*
  766. 获取一个聊天室的详情
  767. */
  768. function getChatRoomDetail($chatroom_id){
  769.     $url=$this->url.'chatrooms/'.$chatroom_id;
  770.     $header=array($this->getToken());
  771.     $result=$this->postCurl($url,'',$header,'GET');
  772.     return $result;
  773. }
  774. /*
  775. 获取一个用户加入的所有聊天室
  776. */
  777. function getChatRoomJoined($username){
  778.     $url=$this->url.'users/'.$username.'/joined_chatrooms';
  779.     $header=array($this->getToken());
  780.     $result=$this->postCurl($url,'',$header,'GET');
  781.     return $result;
  782. }
  783. /*
  784. 聊天室单个成员添加
  785. */
  786. function addChatRoomMember($chatroom_id,$username){
  787.     $url=$this->url.'chatrooms/'.$chatroom_id.'/users/'.$username;
  788.     //$header=array($this->getToken());
  789.     $header=array($this->getToken(),'Content-Type:application/json');
  790.     $result=$this->postCurl($url,'',$header);
  791.     return $result;
  792. }
  793. /*
  794. 聊天室批量成员添加
  795. */
  796. function addChatRoomMembers($chatroom_id,$usernames){
  797.     $url=$this->url.'chatrooms/'.$chatroom_id.'/users';
  798.     $body=json_encode($usernames);
  799.     $header=array($this->getToken());
  800.     $result=$this->postCurl($url,$body,$header);
  801.     return $result;
  802. }
  803. /*
  804. 聊天室单个成员删除
  805. */
  806. function deleteChatRoomMember($chatroom_id,$username){
  807.     $url=$this->url.'chatrooms/'.$chatroom_id.'/users/'.$username;
  808.     $header=array($this->getToken());
  809.     $result=$this->postCurl($url,'',$header,'DELETE');
  810.     return $result;
  811. }
  812. /*
  813. 聊天室批量成员删除
  814. */
  815. function deleteChatRoomMembers($chatroom_id,$usernames){
  816.     $url=$this->url.'chatrooms/'.$chatroom_id.'/users/'.$usernames;
  817.     //$body=json_encode($usernames);
  818.     $header=array($this->getToken());
  819.     $result=$this->postCurl($url,'',$header,'DELETE');
  820.     return $result;
  821. }
  822. //-------------------------------------------------------------聊天记录
  823.  
  824. /*
  825. 导出聊天记录----不分页
  826. */
  827. function getChatRecord($ql){
  828.     if(!empty($ql)){
  829.         $url=$this->url.'chatmessages?ql='.$ql;
  830.     }else{
  831.         $url=$this->url.'chatmessages';
  832.     }
  833.     $header=array($this->getToken());
  834.     $result=$this->postCurl($url,'',$header,"GET");
  835.     return $result;
  836. }
  837. /*
  838. 导出聊天记录---分页
  839. */
  840. function getChatRecordForPage($ql,$limit=0,$cursor){
  841.     if(!empty($ql)){
  842.         $url=$this->url.'chatmessages?ql='.$ql.'&limit='.$limit.'&cursor='.$cursor;
  843.     }
  844.     $header=array($this->getToken());
  845.     $result=$this->postCurl($url,'',$header,"GET");
  846.     $cursor=isset ( $result["cursor"] ) ? $result["cursor"] : '-1';
  847.     $this->writeCursor("chatfile.txt",$cursor);
  848.     //var_dump($GLOBALS['cursor'].'00000000000000');
  849.     return $result;
  850. }
  851.  
  852. /**
  853. *$this->postCurl方法
  854. */
  855. function postCurl($url,$body,$header,$type="POST"){
  856.     //1.创建一个curl资源
  857.     $ch = curl_init();
  858.     //2.设置URL和相应的选项
  859.     curl_setopt($ch,CURLOPT_URL,$url);//设置url
  860.     //1)设置请求头
  861.     //array_push($header, 'Accept:application/json');
  862.     //array_push($header,'Content-Type:application/json');
  863.     //array_push($header, 'http:multipart/form-data');
  864.     //设置为false,只会获得响应的正文(true的话会连响应头一并获取到)
  865.     curl_setopt($ch,CURLOPT_HEADER,0);
  866.     // curl_setopt ( $ch, CURLOPT_TIMEOUT,5); // 设置超时限制防止死循环
  867.     //设置发起连接前的等待时间，如果设置为0，则无限等待。
  868.     curl_setopt($ch,CURLOPT_CONNECTTIMEOUT,5);
  869.     //将curl_exec()获取的信息以文件流的形式返回，而不是直接输出。
  870.     curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
  871.     //2)设备请求体
  872.     if (count($body)>0) {
  873.         //$b=json_encode($body,true);
  874.         curl_setopt($ch, CURLOPT_POSTFIELDS, $body);//全部数据使用HTTP协议中的"POST"操作来发送。
  875.     }
  876.     //设置请求头
  877.     if(count($header)>0){
  878.         curl_setopt($ch,CURLOPT_HTTPHEADER,$header);
  879.     }
  880.     //上传文件相关设置
  881.     curl_setopt($ch, CURLOPT_FOLLOWLOCATION, true);
  882.     curl_setopt($ch, CURLOPT_MAXREDIRS, 3);
  883.     curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);// 对认证证书来源的检查
  884.     curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, 0);// 从证书中检查SSL加密算
  885.  
  886.  
  887.     //3)设置提交方式
  888.     switch($type){
  889.         case "GET":
  890.             curl_setopt($ch,CURLOPT_HTTPGET,true);
  891.             break;
  892.         case "POST":
  893.             curl_setopt($ch,CURLOPT_POST,true);
  894.             break;
  895.         case "PUT"://使用一个自定义的请求信息来代替"GET"或"HEAD"作为HTTP请求。这对于执行"DELETE" 或者其他更隐蔽的HTT
  896.             curl_setopt($ch,CURLOPT_CUSTOMREQUEST,"PUT");
  897.             break;
  898.         case "DELETE":
  899.             curl_setopt($ch,CURLOPT_CUSTOMREQUEST,"DELETE");
  900.             break;
  901.     }
  902.  
  903.  
  904.     //4)在HTTP请求中包含一个"User-Agent: "头的字符串。-----必设
  905.  
  906.     // curl_setopt($ch, CURLOPT_USERAGENT, 'SSTS Browser/1.0');
  907.     // curl_setopt($ch, CURLOPT_ENCODING, 'gzip');
  908.     
  909.     curl_setopt ( $ch, CURLOPT_USERAGENT, 'Mozilla/4.0 (compatible; MSIE 8.0; Windows NT 6.0; Trident/4.0)' ); // 模拟用户使用的浏览器
  910.     //5)
  911.  
  912.  
  913.     //3.抓取URL并把它传递给浏览器
  914.     $res=curl_exec($ch);
  915.  
  916.  
  917.     $result=json_decode($res,true);
  918.     //4.关闭curl资源，并且释放系统资源
  919.     curl_close($ch);
  920.     if(empty($result))
  921.         return $res;
  922.     else
  923.         return $result;
  924.  
  925.     }
  926. }
  927. ?>

 

声明：本文内容由网友自发贡献，转载请注明出处：【wpsshop博客】
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号