<?php

namespace Home\Controller;

use Think\Controller;

/**

 * 环信-服务器端REST API

 * @author    limx <limx@xiaoneimimi.com>

 */

class HXController extends Controller {

    private $client_id='YXA6ef0hcJSyEeWlQg0wFqthDQ';

    private $client_secret='YXA6dd1GuLATzkHcqqTI3OIgLExnOiI';

    private $org_name='ipa361';

    private $app_name='cg';

    private $url = 'https://a1.easemob.com/ipa361/cg/';

    /**

     * 初始化参数

     *

     * @param array $options

     * @param $options['client_id']

     * @param $options['client_secret']

     * @param $options['org_name']

     * @param $options['app_name']

     */

    /* public function __construct($options) {

        $this->client_id = isset ( $options ['client_id'] ) ? $options ['client_id'] : '';

        $this->client_secret = isset ( $options ['client_secret'] ) ? $options ['client_secret'] : '';

        $this->org_name = isset ( $options ['org_name'] ) ? $options ['org_name'] : '';

        $this->app_name = isset ( $options ['app_name'] ) ? $options ['app_name'] : '';

        if (! empty ( $this->org_name ) && ! empty ( $this->app_name )) {

            $this->url = 'https://a1.easemob.com/' . $this->org_name . '/' . $this->app_name . '/';

        }

    } */

    /**

     * 开放注册模式

     *

     * @param $options['username'] 用户名

     * @param $options['password'] 密码

     * 设置密码为账号+_ipa做加密运算

     */

    public function openRegister($username) {

        $options['username']=$username;

        //$tripldes =new TripledesModel();

        $tripldes =D("Tripledes");

        $pass= $tripldes->encrypt($username.'_ipa');

        $options['password']=$pass;

        //$options['password']=123456;

        $url = $this->url . "users";

        $result = $this->postCurl ( $url, $options, $head = 0 );

        //echo $result ;exit;

        $info = json_decode($result,true);

        //dump($info);

        //echo $info ;exit;

        if(isset($info['entities'])){

            return '1';

        }else{

            return '0';

        }

    }

    public function test(){

        $des =D("Tripledes");

        echo $ret = $des->encrypt("123") . "\n";

        echo $des->decrypt($ret) . "\n";

        $info = array(

            'msg'=>'成功',

            'code'=>200,

            'ret'=>$ret,

            'des'=>$des);

        echo json_encode($info);

    }

    /**

     * 授权注册模式 || 批量注册

     *

     * @param $options['username'] 用户名

     * @param $options['password'] 密码

     *          批量注册传二维数组

     */

    public function accreditRegister($options) {

        $url = $this->url . "users";

        $access_token = $this->getToken ();

        $header [] = 'Authorization: Bearer ' . $access_token;

        $result = $this->postCurl ( $url, $options, $header );

        //return $result;

        echo $result;

    }

    /**

     * 获取指定用户详情

     *

     * @param $username 用户名

     */

    public function userDetails($username) {

        $url = $this->url . "users/" . $username;

        $access_token = $this->getToken ();

        //print_r($access_token);exit;

        $header [] = 'Authorization: Bearer ' . $access_token;

        $result = $this->postCurl ( $url, '', $header, $type = 'GET' );

        $info = json_decode($result,true);

        //print_r($info);

        if(isset($info['entities'])){

            return '1';

        }else{

            return '0';

        }

    }

    /**

     * 重置用户密码

     *

     * @param $options['username'] 用户名

     * @param $options['password'] 密码

     * @param $options['newpassword'] 新密码

     */

    public function editPassword($options) {

        $url = $this->url . "users/" . $options ['username'] . "/password";

        $access_token = $this->getToken ();

        $header [] = 'Authorization: Bearer ' . $access_token;

        $result = $this->postCurl ( $url, $options, $header, $type = 'PUT');

        return $result;

    }

    /**

     * 删除用户

     *

     * @param $username 用户名

     */

    public function deleteUser($username) {

        $url = $this->url . "users/" . $username;

        $access_token = $this->getToken ();

        $header [] = 'Authorization: Bearer ' . $access_token;

        $result = $this->postCurl ( $url, '', $header, $type = 'DELETE' );

    }

    /**

     * 批量删除用户

     * 描述：删除某个app下指定数量的环信账号。上述url可一次删除300个用户,数值可以修改 建议这个数值在100-500之间，不要过大

     *

     * @param $limit="300" 默认为300条

     * @param $ql 删除条件

     *          如ql=order+by+created+desc 按照创建时间来排序(降序)

     */

    public function batchDeleteUser($limit = "300", $ql = '') {

        $url = $this->url . "users?limit=" . $limit;

        if (! empty ( $ql )) {

            $url = $this->url . "users?ql=" . $ql . "&limit=" . $limit;

        }

        $access_token = $this->getToken ();

        $header [] = 'Authorization: Bearer ' . $access_token;

        $result = $this->postCurl ( $url, '', $header, $type = 'DELETE' );

    }

    /**

     * 给一个用户添加一个好友

     *

     * @param

     *          $owner_username

     * @param

     *          $friend_username

     */

    public function addFriend($owner_username, $friend_username) {

        $url = $this->url . "users/" . $owner_username . "/contacts/users/" . $friend_username;

        $access_token = $this->getToken ();

        $header [] = 'Authorization: Bearer ' . $access_token;

        $result = $this->postCurl ( $url, '', $header );

    }

    /**

     * 删除好友

     *

     * @param

     *          $owner_username

     * @param

     *          $friend_username

     */

    public function deleteFriend($owner_username, $friend_username) {

        $url = $this->url . "users/" . $owner_username . "/contacts/users/" . $friend_username;

        $access_token = $this->getToken ();

        $header [] = 'Authorization: Bearer ' . $access_token;

        $result = $this->postCurl ( $url, '', $header, $type = "DELETE" );

    }

    /**

     * 查看用户的好友

     *

     * @param

     *          $owner_username

     */

    public function showFriend($owner_username) {

        $url = $this->url . "users/" . $owner_username . "/contacts/users/";

        $access_token = $this->getToken ();

        $header [] = 'Authorization: Bearer ' . $access_token;

        $result = $this->postCurl ( $url, '', $header, $type = "GET" );

    }

    // +----------------------------------------------------------------------

    // | 聊天相关的方法

    // +----------------------------------------------------------------------

    /**

     * 查看用户是否在线

     *

     * @param

     *          $username

     */

    public function isOnline($username) {

        $url = $this->url . "users/" . $username . "/status";

        $access_token = $this->getToken ();

        $header [] = 'Authorization: Bearer ' . $access_token;

        $result = $this->postCurl ( $url, '', $header, $type = "GET" );

        //return $result;

        echo $result;

    }

    /**

     * 发送消息

     *

     * @param string $from_user

     *          发送方用户名

     * @param array $username

     *          array('1','2')

     * @param string $target_type

     *          默认为：users 描述：给一个或者多个用户(users)或者群组发送消息(chatgroups)

     * @param string $content

     * @param array $ext

     *          自定义参数

     */

    function yy_hxSend($from_user = "admin", $username, $content, $target_type = "users", $ext) {

        $option ['target_type'] = $target_type;

        $option ['target'] = $username;

        $params ['type'] = "txt";

        $params ['msg'] = $content;

        $option ['msg'] = $params;

        $option ['from'] = $from_user;

        $option ['ext'] = $ext;

        $url = $this->url . "messages";

        $access_token = $this->getToken ();

        $header [] = 'Authorization: Bearer ' . $access_token;

        $result = $this->postCurl ( $url, $option, $header );

        return $result;

    }

    /**

     * 获取app中所有的群组

     */

    public function chatGroups() {

        $url = $this->url . "chatgroups";

        $access_token = $this->getToken ();

        $header [] = 'Authorization: Bearer ' . $access_token;

        $result = $this->postCurl ( $url, '', $header, $type = "GET" );

        return $result;

    }

    /**

     * 创建群组

     *

     * @param $option['groupname'] //群组名称,

     *          此属性为必须的

     * @param $option['desc'] //群组描述,

     *          此属性为必须的

     * @param $option['public'] //是否是公开群,

     *          此属性为必须的 true or false

     * @param $option['approval'] //加入公开群是否需要批准,

     *          没有这个属性的话默认是true, 此属性为可选的

     * @param $option['owner'] //群组的管理员,

     *          此属性为必须的

     * @param $option['members'] //群组成员,此属性为可选的

     */

    public function createGroups($option) {

        $url = $this->url . "chatgroups";

        $access_token = $this->getToken ();

        $header [] = 'Authorization: Bearer ' . $access_token;

        $result = $this->postCurl ( $url, $option, $header );

        return $result;

    }

    /**

     * 获取群组详情

     *

     * @param

     *          $group_id

     */

    public function chatGroupsDetails($group_id) {

        $url = $this->url . "chatgroups/" . $group_id;

        $access_token = $this->getToken ();

        $header [] = 'Authorization: Bearer ' . $access_token;

        $result = $this->postCurl ( $url, '', $header, $type = "GET" );

        return $result;

    }

    /**

     * 删除群组

     *

     * @param

     *          $group_id

     */

    public function deleteGroups($group_id) {

        $url = $this->url . "chatgroups/" . $group_id;

        $access_token = $this->getToken ();

        $header [] = 'Authorization: Bearer ' . $access_token;

        $result = $this->postCurl ( $url, '', $header, $type = "DELETE" );

        return $result;

    }

    /**

     * 获取群组成员

     *

     * @param

     *          $group_id

     */

    public function groupsUser($group_id) {

        $url = $this->url . "chatgroups/" . $group_id . "/users";

        $access_token = $this->getToken ();

        $header [] = 'Authorization: Bearer ' . $access_token;

        $result = $this->postCurl ( $url, '', $header, $type = "GET" );

        $info = json_decode($result,true);

        if(isset($info['data'])){

            return $info['data'];

        }else{

            return '0';

        }

        return $result;

    }

    /**

     * 群组添加成员

     *

     * @param

     *          $group_id

     * @param

     *          $username

     */

    public function addGroupsUser($group_id, $username) {

        $url = $this->url . "chatgroups/" . $group_id . "/users/" . $username;

        $access_token = $this->getToken ();

        $header [] = 'Authorization: Bearer ' . $access_token;

        $result = $this->postCurl ( $url, '', $header, $type = "POST" );

        return $result;

    }

    /**

     * 群组删除成员

     *

     * @param

     *          $group_id

     * @param

     *          $username

     */

    public function delGroupsUser($group_id, $username) {

        $url = $this->url . "chatgroups/" . $group_id . "/users/" . $username;

        $access_token = $this->getToken ();

        $header [] = 'Authorization: Bearer ' . $access_token;

        $result = $this->postCurl ( $url, '', $header, $type = "DELETE" );

        return $result;

    }

    /**

     * 聊天消息记录

     *

     * @param $ql 查询条件如：$ql

     *          = "select+*+where+from='" . $uid . "'+or+to='". $uid ."'+order+by+timestamp+desc&limit=" . $limit . $cursor;

     *          默认为order by timestamp desc

     * @param $cursor 分页参数

     *          默认为空

     * @param $limit 条数

     *          默认20

     */

    public function chatRecord($ql = '', $cursor = '', $limit = 20) {

        $ql = ! empty ( $ql ) ? "ql=" . $ql : "order+by+timestamp+desc";

        $cursor = ! empty ( $cursor ) ? "&cursor=" . $cursor : '';

        $url = $this->url . "chatmessages?" . $ql . "&limit=" . $limit . $cursor;

        $access_token = $this->getToken ();

        $header [] = 'Authorization: Bearer ' . $access_token;

        $result = $this->postCurl ( $url, '', $header, $type = "GET " );

        return $result;

    }

    //判断某个字段是否存在

    public function checkField($jsons){

        if($jsons->activated==true){

            print_r('11111');

            return true;

        }else{

            print_r('22222');

            return false;

        }

    }

    /**

     * 获取Token

     */

    public function getToken() {

        //print_r($url);exit;

        $option ['grant_type'] = "client_credentials";

        $option ['client_id'] = $this->client_id;

        $option ['client_secret'] = $this->client_secret;

        $url = $this->url . "token";

        $fp = @fopen ( "easemob.txt", 'r' );

        if ($fp) {

            $arr = unserialize ( fgets ( $fp ) );

            if ($arr ['expires_in'] < time ()) {

                $result = $this->postCurl ( $url, $option, $head = 0 );

                //$result ['expires_in'] = $result ['expires_in'] + time ();

                @fwrite ( $fp, serialize ( $result ) );

                $myArr=json_decode($result, true);

                $token=$myArr['access_token'];

                return  $token;

                fclose ( $fp );

                exit ();

            }

            return $arr ['access_token'];

            fclose ( $fp );

            exit ();

        }

        $result = $this->postCurl ( $url, $option, $head = 0 );

        $result = json_decode($result);

        $result ['expires_in'] = $result ['expires_in'] + time ();

        $fp = @fopen ( "easemob.txt", 'w' );

        @fwrite ( $fp, serialize ( $result ) );

        return $result ['access_token'];

        fclose ( $fp );

    }

    /**

     * CURL Post

     */

    private function postCurl($url, $option, $header = 0, $type = 'POST') {

        $curl = curl_init (); // 启动一个CURL会话

        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提交的数据包

        }

        curl_setopt ( $curl, CURLOPT_TIMEOUT, 30 ); // 设置超时限制防止死循环

        curl_setopt ( $curl, CURLOPT_HTTPHEADER, $header ); // 设置HTTP头

        curl_setopt ( $curl, CURLOPT_RETURNTRANSFER, 1 ); // 获取的信息以文件流的形式返回

        curl_setopt ( $curl, CURLOPT_CUSTOMREQUEST, $type );

        $result = curl_exec ( $curl ); // 执行操作

        //$res = object_array ( json_decode ( $result ) );

        //$res ['status'] = curl_getinfo ( $curl, CURLINFO_HTTP_CODE );

        //pre ( $res );

        curl_close ( $curl ); // 关闭CURL会话

        return $result;

    }

    //登录成功后自动检测帐户信息，如果没有创建则创建

    public function autoRegister($username){

        $hasAccount= $this->userDetails($username) ;

        if($hasAccount){

            return '1';

        }else{

        }

    }

    //登录

    public function  login(){

        session_start();

        $sessionid = session_id();//得到sessionid

        //echo $sessionid ;

        //声明一个json数组

        $value=array();

        $username=trim($_REQUEST['username']);

        $password=trim($_REQUEST['password']);

        // $DH=$db->get_one("select * from $thistable where  (username='".trim($username)."' or mobile='".trim($username)."' or (email='".trim($username)."' and email_yz=1)) and del=0 ");

        $islogin=loginaddpoint($username,$password,$type="");

        $user_id = $islogin;

        if($islogin>0){

            //数据库获取用户所有信息

            $umodel = M('user','jo2_');

            $U=$umodel -> where("userid='".$user_id."'") -> find();

            //var_dump($U);

            $_SESSION["userid"]=$U["userid"];

            $_SESSION["username"]=$U["username"];

            $_SESSION["usertype"]=$U["type"];

            $_SESSION["sessionid"]=$sessionid;

            $U['face']=$siteurl.$U['face'];

            $U['face_s']=$U['face_s']?$siteurl.$U['face_s']:'';

            $value['sessionid']=$sessionid;

            $value['account'] = $U['username'];

            $value['user_id'] = $U['userid'];

            $value['msg'] = "登陆成功！";

            $value['code'] = "200";

            if($_GET[isdz]=="1"){

                $json=json_encode($U);

            }else{

                $json=json_encode($value);

            }

            echo $json;

        }else if($islogin == -2){

            $value['msg'] = "密码错误！";

            $value['code'] = "101";

            $json=json_encode($value);

            echo $json;

        }else if($islogin == -1){

            $value['msg'] = "用户名和密码不能为空！";

            $value['code'] = "102";

            $json=json_encode($value);

            echo $json;

        }else if($islogin === 0){

            $value['msg'] = "账号不存在！";

            $value['code'] = "103";

            $json=json_encode($value);

            echo $json;

        }

    }

}

最新文章

  1. Block 使用注意点
  2. JAVA经典算法40题(供面试所用)
  3. 【转】单表60亿记录等大数据场景的MySQL优化和运维之道 | 高可用架构
  4. oracle utf8字符集转gbk(转)
  5. Sticky Footer (让页脚永远停靠在页面底部,而不是根据绝对位置)
  6. Linux命令对应的全称解释（转）
  7. UVa 10226 - Hardwood Species
  8. 运行错误：Application Error - The connection to the server was unsuccessful
  9. 【JavaScript】对JS的封装
  10. Redis基础入门
  11. 4-3 组件参数校验与非props特性
  12. 怎样利用ADO中的adoquery进行缓存更新？？？？？(100分)
  13. python 函数 动态参数 和嵌套
  14. linux上安装redis并使用
  15. MyEclipse启动时 弹出提醒框
  16. spring 之 lookup-method &amp; replaced-method II
  17. ORM操作mysql
  18. Python(多线程threading模块)
  19. 通过微信公众号ID生成公众号的二维码
  20. mysql-cluster 7.3.5-linux 安装

热门文章

  1. css基础（代码）
  2. 非JAVA WEB项目提供Http接口调用实现
  3. SSM框架中的Mapper.xml文件中的增、删、改、查等操作
  4. EF 将MSSQL 更换成 POSTRESQL
  5. JavaWeb【六、JavaBean】
  6. c++第三次作业：类的友元
  7. Selenium（6）
  8. BZOJ 1015 并查集&amp;连通块
  9. 使用SetWindowHookEx注入global hook
  10. 对bloom的理解 及优化