304 lines
11 KiB
PHP
304 lines
11 KiB
PHP
|
<?php
|
||
|
|
/**
|
||
|
|
* 请求发送
|
||
|
|
*/
|
||
|
|
|
||
|
|
namespace RongCloud\Lib;
|
||
|
|
|
||
|
|
use RongCloud\RongCloud;
|
||
|
|
|
||
|
|
class Request {
|
||
|
|
private $appKey = "";
|
||
|
|
private $appSecret = "";
|
||
|
|
// private $serverUrl = 'https://api-rce-rcxtest.rongcloud.net/';
|
||
|
|
private $serverUrl = ['http://api-cn.ronghub.com/', 'http://api2-cn.ronghub.com/'];
|
||
|
|
private $smsUrl = 'http://api.sms.ronghub.com/';
|
||
|
|
|
||
|
|
public function __construct() {
|
||
|
|
if (RongCloud::$appkey) {
|
||
|
|
$this->appKey = RongCloud::$appkey;
|
||
|
|
}
|
||
|
|
if (RongCloud::$appSecret) {
|
||
|
|
$this->appSecret = RongCloud::$appSecret;
|
||
|
|
}
|
||
|
|
if (RongCloud::$apiUrl) {
|
||
|
|
$this->serverUrl = RongCloud::$apiUrl;
|
||
|
|
} else {
|
||
|
|
RongCloud::$apiUrl = $this->serverUrl;
|
||
|
|
}
|
||
|
|
$this->serverUrl = $this->resetServerUrl();
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* server url 多域名切换
|
||
|
|
*/
|
||
|
|
private function resetServerUrl($nextUrl = "") {
|
||
|
|
if (is_array(RongCloud::$apiUrl)) {
|
||
|
|
$urlList = RongCloud::$apiUrl;
|
||
|
|
sort($urlList);
|
||
|
|
RongCloud::$apiUrl = $urlList;
|
||
|
|
}
|
||
|
|
if (is_array(RongCloud::$apiUrl) && count(RongCloud::$apiUrl) == 1) {
|
||
|
|
return RongCloud::$apiUrl[0];
|
||
|
|
}
|
||
|
|
if (is_string(RongCloud::$apiUrl)) {
|
||
|
|
return RongCloud::$apiUrl;
|
||
|
|
}
|
||
|
|
$seesionId = "RongCloudServerSDKUrl";
|
||
|
|
if (!session_id()) {
|
||
|
|
@session_start();
|
||
|
|
}
|
||
|
|
$oldSessionId = session_id();
|
||
|
|
session_write_close();
|
||
|
|
//切换到 sdk Session
|
||
|
|
session_id($seesionId);
|
||
|
|
session_start();
|
||
|
|
|
||
|
|
if (!isset($_SESSION['curl'])) {
|
||
|
|
$_SESSION['curl'] = RongCloud::$apiUrl[0];
|
||
|
|
}
|
||
|
|
if ($nextUrl) {
|
||
|
|
$_SESSION['curl'] = $nextUrl;
|
||
|
|
}
|
||
|
|
|
||
|
|
$currentUrl = isset($_SESSION['curl']) ? $_SESSION['curl'] : RongCloud::$apiUrl[0];
|
||
|
|
session_write_close();
|
||
|
|
unset($_SESSION);
|
||
|
|
//切换到原始 SESSION
|
||
|
|
session_id($oldSessionId);
|
||
|
|
session_start();
|
||
|
|
setcookie("PHPSESSID", $oldSessionId);
|
||
|
|
return $currentUrl;
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* 多域名 设置为下一个域名
|
||
|
|
* @param string $url
|
||
|
|
*/
|
||
|
|
private function getNextUrl($url = "") {
|
||
|
|
$urlList = RongCloud::$apiUrl;
|
||
|
|
if (is_array($urlList) && in_array($url, $urlList)) {
|
||
|
|
$currentKey = array_search($url, $urlList);
|
||
|
|
$nextUrl = isset($urlList[$currentKey + 1]) ? $urlList[$currentKey + 1] : $urlList[0];
|
||
|
|
$this->resetServerUrl($nextUrl);
|
||
|
|
}
|
||
|
|
return true;
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* 创建http header参数
|
||
|
|
* @param array $data
|
||
|
|
* @return bool
|
||
|
|
*/
|
||
|
|
private function createHttpHeader() {
|
||
|
|
$nonce = mt_rand();
|
||
|
|
$timeStamp = time();
|
||
|
|
$sign = sha1($this->appSecret . $nonce . $timeStamp);
|
||
|
|
return [
|
||
|
|
'RC-App-Key:' . $this->appKey,
|
||
|
|
'RC-Nonce:' . $nonce,
|
||
|
|
'RC-Timestamp:' . $timeStamp,
|
||
|
|
'RC-Signature:' . $sign,
|
||
|
|
];
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* 请求发送
|
||
|
|
*
|
||
|
|
* @param $action 接口方法
|
||
|
|
* @param $params 请求参数
|
||
|
|
* @param string $contentType 接口返回数据类型 默认 json
|
||
|
|
* @param string $module 接口请求模块 默认 im
|
||
|
|
* @param string $httpMethod 接口请求方式 默认 POST
|
||
|
|
* @return int|mixed
|
||
|
|
*/
|
||
|
|
public function Request($action, $params, $contentType = 'urlencoded', $module = 'im', $httpMethod = 'POST') {
|
||
|
|
switch ($module) {
|
||
|
|
case 'im':
|
||
|
|
$action = $this->serverUrl . $action;
|
||
|
|
break;
|
||
|
|
case 'sms':
|
||
|
|
$action = $this->smsUrl . $action;
|
||
|
|
break;
|
||
|
|
default:
|
||
|
|
$action = $this->serverUrl . $action;
|
||
|
|
}
|
||
|
|
|
||
|
|
$httpHeader = $this->createHttpHeader();
|
||
|
|
$ch = curl_init();
|
||
|
|
if ($contentType == "urlencoded" || $contentType == "json") {
|
||
|
|
$action .= ".json";
|
||
|
|
} else {
|
||
|
|
$action .= ".xml";
|
||
|
|
}
|
||
|
|
if ($httpMethod == 'POST' && $contentType == 'urlencoded') {
|
||
|
|
$httpHeader[] = 'Content-Type:application/x-www-form-urlencoded';
|
||
|
|
curl_setopt($ch, CURLOPT_POSTFIELDS, $this->build_query($params));
|
||
|
|
}
|
||
|
|
if ($httpMethod == 'POST' && $contentType == 'json') {
|
||
|
|
$httpHeader[] = 'Content-Type:application/json';
|
||
|
|
curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($params));
|
||
|
|
}
|
||
|
|
if ($httpMethod == 'GET' && $contentType == 'urlencoded') {
|
||
|
|
$action .= strpos($action, '?') === false ? '?' : '&';
|
||
|
|
$action .= $this->build_query($params);
|
||
|
|
}
|
||
|
|
curl_setopt($ch, CURLOPT_URL, $action);
|
||
|
|
curl_setopt($ch, CURLOPT_POST, $httpMethod == 'POST');
|
||
|
|
curl_setopt($ch, CURLOPT_HTTPHEADER, $httpHeader);
|
||
|
|
curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false); //处理http证书问题
|
||
|
|
curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
|
||
|
|
curl_setopt($ch, CURLOPT_HEADER, false);
|
||
|
|
curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 20);
|
||
|
|
curl_setopt($ch, CURLOPT_TIMEOUT, 30);
|
||
|
|
curl_setopt($ch, CURLOPT_USERAGENT, "rc-php-sdk/3.0.11");
|
||
|
|
// curl_setopt($ch, CURLOPT_DNS_USE_GLOBAL_CACHE, false);
|
||
|
|
curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
|
||
|
|
$ret = curl_exec($ch);
|
||
|
|
if (false === $ret) {
|
||
|
|
$ret = curl_errno($ch);
|
||
|
|
$ret = $this->getCurlError($ret);
|
||
|
|
}
|
||
|
|
$httpInfo = curl_getinfo($ch);
|
||
|
|
curl_close($ch);
|
||
|
|
$result = json_decode($ret, true);
|
||
|
|
if (isset($result['code']) && $result['code'] == 1000) {
|
||
|
|
|
||
|
|
}
|
||
|
|
if ($module == "im" && $httpInfo['http_code'] >= 500 && $httpInfo['http_code'] < 600) {
|
||
|
|
$this->getNextUrl($this->serverUrl);
|
||
|
|
}
|
||
|
|
|
||
|
|
return $ret;
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* 生成参数体
|
||
|
|
*
|
||
|
|
* @param $formData
|
||
|
|
* @param string $numericPrefix
|
||
|
|
* @param string $argSeparator
|
||
|
|
* @param string $prefixKey
|
||
|
|
* @return bool|string
|
||
|
|
*/
|
||
|
|
private function build_query($formData, $numericPrefix = '', $argSeparator = '&', $prefixKey = '') {
|
||
|
|
$str = '';
|
||
|
|
foreach ($formData as $key => $val) {
|
||
|
|
if (!is_array($val)) {
|
||
|
|
$str .= $argSeparator;
|
||
|
|
if ($prefixKey === '') {
|
||
|
|
if (is_int($key)) {
|
||
|
|
$str .= $numericPrefix;
|
||
|
|
}
|
||
|
|
$str .= urlencode($key) . '=' . urlencode($val);
|
||
|
|
} else {
|
||
|
|
$str .= urlencode($prefixKey) . '=' . urlencode($val);
|
||
|
|
}
|
||
|
|
} else {
|
||
|
|
if ($prefixKey == '') {
|
||
|
|
$prefixKey .= $key;
|
||
|
|
}
|
||
|
|
if (isset($val[0]) && is_array($val[0])) {
|
||
|
|
$arr = array();
|
||
|
|
$arr[$key] = $val[0];
|
||
|
|
$str .= $argSeparator . http_build_query($arr);
|
||
|
|
} else {
|
||
|
|
$str .= $argSeparator . $this->build_query($val, $numericPrefix, $argSeparator, $prefixKey);
|
||
|
|
}
|
||
|
|
$prefixKey = '';
|
||
|
|
}
|
||
|
|
}
|
||
|
|
return substr($str, strlen($argSeparator));
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* curl 请求错误信息
|
||
|
|
* @param int $error
|
||
|
|
*/
|
||
|
|
public function getCurlError($error = 1) {
|
||
|
|
$errorCodes = array(
|
||
|
|
1 => 'CURLE_UNSUPPORTED_PROTOCOL',
|
||
|
|
2 => 'CURLE_FAILED_INIT',
|
||
|
|
3 => 'CURLE_URL_MALFORMAT',
|
||
|
|
4 => 'CURLE_URL_MALFORMAT_USER',
|
||
|
|
5 => 'CURLE_COULDNT_RESOLVE_PROXY',
|
||
|
|
6 => 'CURLE_COULDNT_RESOLVE_HOST',
|
||
|
|
7 => 'CURLE_COULDNT_CONNECT',
|
||
|
|
8 => 'CURLE_FTP_WEIRD_SERVER_REPLY',
|
||
|
|
9 => 'CURLE_REMOTE_ACCESS_DENIED',
|
||
|
|
11 => 'CURLE_FTP_WEIRD_PASS_REPLY',
|
||
|
|
13 => 'CURLE_FTP_WEIRD_PASV_REPLY',
|
||
|
|
14 => 'CURLE_FTP_WEIRD_227_FORMAT',
|
||
|
|
15 => 'CURLE_FTP_CANT_GET_HOST',
|
||
|
|
17 => 'CURLE_FTP_COULDNT_SET_TYPE',
|
||
|
|
18 => 'CURLE_PARTIAL_FILE',
|
||
|
|
19 => 'CURLE_FTP_COULDNT_RETR_FILE',
|
||
|
|
21 => 'CURLE_QUOTE_ERROR',
|
||
|
|
22 => 'CURLE_HTTP_RETURNED_ERROR',
|
||
|
|
23 => 'CURLE_WRITE_ERROR',
|
||
|
|
25 => 'CURLE_UPLOAD_FAILED',
|
||
|
|
26 => 'CURLE_READ_ERROR',
|
||
|
|
27 => 'CURLE_OUT_OF_MEMORY',
|
||
|
|
28 => 'CURLE_OPERATION_TIMEDOUT',
|
||
|
|
30 => 'CURLE_FTP_PORT_FAILED',
|
||
|
|
31 => 'CURLE_FTP_COULDNT_USE_REST',
|
||
|
|
33 => 'CURLE_RANGE_ERROR',
|
||
|
|
34 => 'CURLE_HTTP_POST_ERROR',
|
||
|
|
35 => 'CURLE_SSL_CONNECT_ERROR',
|
||
|
|
36 => 'CURLE_BAD_DOWNLOAD_RESUME',
|
||
|
|
37 => 'CURLE_FILE_COULDNT_READ_FILE',
|
||
|
|
38 => 'CURLE_LDAP_CANNOT_BIND',
|
||
|
|
39 => 'CURLE_LDAP_SEARCH_FAILED',
|
||
|
|
41 => 'CURLE_FUNCTION_NOT_FOUND',
|
||
|
|
42 => 'CURLE_ABORTED_BY_CALLBACK',
|
||
|
|
43 => 'CURLE_BAD_FUNCTION_ARGUMENT',
|
||
|
|
45 => 'CURLE_INTERFACE_FAILED',
|
||
|
|
47 => 'CURLE_TOO_MANY_REDIRECTS',
|
||
|
|
48 => 'CURLE_UNKNOWN_TELNET_OPTION',
|
||
|
|
49 => 'CURLE_TELNET_OPTION_SYNTAX',
|
||
|
|
51 => 'CURLE_PEER_FAILED_VERIFICATION',
|
||
|
|
52 => 'CURLE_GOT_NOTHING',
|
||
|
|
53 => 'CURLE_SSL_ENGINE_NOTFOUND',
|
||
|
|
54 => 'CURLE_SSL_ENGINE_SETFAILED',
|
||
|
|
55 => 'CURLE_SEND_ERROR',
|
||
|
|
56 => 'CURLE_RECV_ERROR',
|
||
|
|
58 => 'CURLE_SSL_CERTPROBLEM',
|
||
|
|
59 => 'CURLE_SSL_CIPHER',
|
||
|
|
60 => 'CURLE_SSL_CACERT',
|
||
|
|
61 => 'CURLE_BAD_CONTENT_ENCODING',
|
||
|
|
62 => 'CURLE_LDAP_INVALID_URL',
|
||
|
|
63 => 'CURLE_FILESIZE_EXCEEDED',
|
||
|
|
64 => 'CURLE_USE_SSL_FAILED',
|
||
|
|
65 => 'CURLE_SEND_FAIL_REWIND',
|
||
|
|
66 => 'CURLE_SSL_ENGINE_INITFAILED',
|
||
|
|
67 => 'CURLE_LOGIN_DENIED',
|
||
|
|
68 => 'CURLE_TFTP_NOTFOUND',
|
||
|
|
69 => 'CURLE_TFTP_PERM',
|
||
|
|
70 => 'CURLE_REMOTE_DISK_FULL',
|
||
|
|
71 => 'CURLE_TFTP_ILLEGAL',
|
||
|
|
72 => 'CURLE_TFTP_UNKNOWNID',
|
||
|
|
73 => 'CURLE_REMOTE_FILE_EXISTS',
|
||
|
|
74 => 'CURLE_TFTP_NOSUCHUSER',
|
||
|
|
75 => 'CURLE_CONV_FAILED',
|
||
|
|
76 => 'CURLE_CONV_REQD',
|
||
|
|
77 => 'CURLE_SSL_CACERT_BADFILE',
|
||
|
|
78 => 'CURLE_REMOTE_FILE_NOT_FOUND',
|
||
|
|
79 => 'CURLE_SSH',
|
||
|
|
80 => 'CURLE_SSL_SHUTDOWN_FAILED',
|
||
|
|
81 => 'CURLE_AGAIN',
|
||
|
|
82 => 'CURLE_SSL_CRL_BADFILE',
|
||
|
|
83 => 'CURLE_SSL_ISSUER_ERROR',
|
||
|
|
84 => 'CURLE_FTP_PRET_FAILED',
|
||
|
|
84 => 'CURLE_FTP_PRET_FAILED',
|
||
|
|
85 => 'CURLE_RTSP_CSEQ_ERROR',
|
||
|
|
86 => 'CURLE_RTSP_SESSION_ERROR',
|
||
|
|
87 => 'CURLE_FTP_BAD_FILE_LIST',
|
||
|
|
88 => 'CURLE_CHUNK_FAILED');
|
||
|
|
if (isset($errorCodes[$error])) {
|
||
|
|
return $errorCodes[$error];
|
||
|
|
} else {
|
||
|
|
return "CURLE_UNKNOW_ERROR";
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
}
|