环信用户导入PHP

$hxurl = "https://a1.easemob.com/51xxx/aaaa/";
/**
     * 批量删除用户
     * 描述：删除某个app下指定数量的环信账号。上述url可一次删除300个用户,数值可以修改 建议这个数值在100-500之间，不要过大
     *
     * @param $limit="300" 默认为300条          
     * @param $ql 删除条件
     *          如ql=order+by+created+desc 按照创建时间来排序(降序)
     */
    function batchDeleteUser($limit = "300", $ql = ‘‘) {
        global $hxurl;
        $url = $hxurl."users?limit=" . $limit;
        if (! empty ( $ql )) {
            $url = $hxurl."users?ql=" . $ql . "&limit=" . $limit;
        }
        $header = array(_get_token());
        $result = _curl_request( $url, ‘‘, $header, $type = ‘DELETE‘ );
        return $result;
    }

    /**
     * 更改用户昵称
     * @param  [string] $username [用户名称]
     * @param  [string] $nickname [用户昵称]
     *
     */
    function editNick($username,$nickname) {
        global $hxurl;
        $formgettoken = $hxurl."users/" . $username;
        $body=array(
            "username"=>$username,
            "nickname"=>$nickname,
        );
        $patoken=json_encode($body);
        $header = array(_get_token());
        $result = _curl_request( $formgettoken, $patoken, $header, $type = ‘PUT‘);
        return $result;
    }
    /**
     * 授权注册模式 || 批量注册
     *
     * @param $options[‘username‘] 用户名          
     * @param $options[‘password‘] 密码
     *          批量注册传二维数组
     */
    function accreditRegister($options) {
        global $hxurl;
        $formgettoken = $hxurl."users";
        $header = array(_get_token());
        $result = _curl_request ( $formgettoken, json_encode($options), $header );
        return $result;
    }


//授权注册模式 POST /{org_name}/{app_name}/users
function registerToken($username,$pwd,$nickname=‘‘)
{
    global $hxurl;
    $formgettoken=$hxurl."users";
    $body=array(
        "username"=>$username,
        "password"=>$pwd,
        ‘nickname‘=>$nickname
    );
    $patoken=json_encode($body);
    $header = array(_get_token());
    $res = _curl_request($formgettoken,$patoken,$header);

    $arrayResult =  json_decode($res, true);    
    return $arrayResult ;
}
//重置用户密码 PUT /{org_name}/{app_name}/users/{username}/password
function changePwdToken($nikename,$newpwd)
{
    global $hxurl;
    $formgettoken=$hxurl."users/".$nikename."/password";
    $body=array(
        "newpassword"=>$newpwd,
    );
    $patoken=json_encode($body);
    $header = array(_get_token());
    $method = "PUT";
    $res = _curl_request($formgettoken,$patoken,$header,$method);
    $arrayResult =  json_decode($res, true);    
    return $arrayResult ;
}
//删除 DELETE /{org_name}/{app_name}/users/{username}
function delUserToken($nikename)
{
    global $hxurl;
    $formgettoken=$hxurl."users/".$nikename;
    $body=array();
    $patoken=json_encode($body);
    $header = array(_get_token());
    $method = "DELETE";
    $res = _curl_request($formgettoken,$patoken,$header,$method);
    $arrayResult =  json_decode($res, true);    
    return $arrayResult ;
}

//先获取app管理员token POST /{org_name}/{app_name}/token
function _get_token()
{
    global $hxurl;
    $formgettoken=$hxurl."token";
    $body=array(
    "grant_type"=>"client_credentials",
    "client_id"=>"xxxxxxxxxxxxxxxxxxxxx",
    "client_secret"=>"xxxxxxxxxxxxxxxxxxxxxx"
    );
    $patoken=json_encode($body);
    $res = _curl_request($formgettoken,$patoken);
    $tokenResult = array();
    
    $tokenResult =  json_decode($res, true);
    //var_dump($tokenResult);
    return "Authorization: Bearer ". $tokenResult["access_token"];  
}

function _curl_request($url, $body, $header = array(), $method = "POST")
{
    array_push($header, ‘Accept:application/json‘);
    array_push($header, ‘Content-Type:application/json‘);

    $ch = curl_init();
    curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 60);
    curl_setopt($ch, CURLOPT_URL, $url);
    curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
    //curl_setopt($ch, $method, 1);
    
    switch ($method){ 
        case "GET" : 
            curl_setopt($ch, CURLOPT_HTTPGET, true);
        break; 
        case "POST": 
            curl_setopt($ch, CURLOPT_POST,true); 
        break; 
        case "PUT" : 
            curl_setopt($ch, CURLOPT_CUSTOMREQUEST, "PUT"); 
        break; 
        case "DELETE":
            curl_setopt ($ch, CURLOPT_CUSTOMREQUEST, "DELETE"); 
        break; 
    }
    
    curl_setopt($ch, CURLOPT_USERAGENT, ‘SSTS Browser/1.0‘);
    curl_setopt($ch, CURLOPT_ENCODING, ‘gzip‘);
    curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, FALSE);
    curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, 1);
    if (isset($body{3}) > 0) {
        curl_setopt($ch, CURLOPT_POSTFIELDS, $body);
    }
    if (count($header) > 0) {
        curl_setopt($ch, CURLOPT_HTTPHEADER, $header);
    }

    $ret = curl_exec($ch);
    $err = curl_error($ch);
    $err = curl_getinfo($ch,CURLINFO_HTTP_CODE); //设置返回状态码
    curl_close($ch);
    //clear_object($ch);
    //clear_object($body);
    //clear_object($header);

    if ($err) {
        return $err;
    }

    return $ret;
}

环信用户导入PHP

原文：http://my.oschina.net/sorenring/blog/525944