<?php
/**
* 接口调用
* ============================================================================
* * 版权所有 蜘蛛行 * *
* 网站地址: http://www.zhizhuchuxing.com
* ----------------------------------------------------------------------------
* 这不是一个自由软件！您只能在不用于商业目的的前提下对程序代码进行修改和
* 使用；不允许对程序代码以任何形式任何目的的再发布。
* ============================================================================
* Author By: 倪宗锋
* PhpStorm CurlInterface.php
* Create By 2016/11/10 13:20 $
*/
namespace addons\nzf;
class CurlInterface
{
protected $url = null;
protected $verb = 'GET';
protected $body = '';
protected $requestLength = 0;
protected $baseUrl = null;
protected $timeOut = 200;
protected $clientId = 1;//站点类型 1 微信
protected $responseBody = null;//接收到的返回值
protected $notReturn = false; //是否有返回值
protected $siteConfig = null; //配置参数
protected $curlGetInfo = null;//交易概要
private $logMessage = ''; //日志内容
private $curlOptHeader = 0; //是否返回头部信息
private $bodyType = 1;
private $cert = false;//是否使用证书
private $certPem;
private $keyPem;
/****************============类的初始化=============*******************/
/**
* @param null $body 2:xml
* @param int $type 1:json 2:xml 3 发送原数据接收xml 4 发送原数据 接收json 5:都是原数据
*/
public function __construct($body = null, $type = 1)
{
$this->setBody($body, $type);
$this->setBaseUrl();
}
/*****************==========参数设置函数开始=========******************/
/**
* Function Description:设置是否返回头部信息
* Function Name: setCurlOptHeader
* @param $curlOptHeader
*
*
* @author 倪宗锋
*/
public function setCurlOptHeader($curlOptHeader)
{
$this->curlOptHeader = $curlOptHeader;
}
/**
* Function Description:获取交易概要
* Function Name: getCurlGetInfo
*
* @return null
*
* @author 倪宗锋
*/
public function getCurlGetInfo()
{
return $this->curlGetInfo;
}
/**
* Function Description:获取返回值报文
* Function Name: getResponseBody
*
* @return null
*
* @author 倪宗锋
*/
public function getResponseBody()
{
return $this->responseBody;
}
/**
* Function Description:获取全路径地址
* Function Name: getUrl
*
* @return null
*
* @author 倪宗锋
*/
public function getUrl()
{
return $this->url;
}
/**
* Function Description:设置路径 在baseUrl基础上
* Function Name: setUrl
* @param $url
*
*
* @author 倪宗锋
*/
public function setUrl($url)
{
$this->url = $this->baseUrl . $url;
}
/**
* Function Description:设置过期时间
* Function Name: setTimeOut
* @param $timeOut
*
*
* @author 倪宗锋
*/
public function setTimeOut($timeOut)
{
$this->timeOut = $timeOut;
}
/**
* Function Description:设置传值方式
* Function Name: setVerb
* @param $verb
*
*
* @author 倪宗锋
*/
public function setVerb($verb)
{
$this->verb = $verb;
}
/**
* Function Description:设置baseUrl
* Function Name: setBaseUrl
* @param $baseUrl string
*
* @author 倪宗锋
*/
public function setBaseUrl($baseUrl = '')
{
$this->baseUrl = $baseUrl;
}
/**
* Function Description:获取BaseUrl
* Function Name: getBaseUrl
*
* @return null
*
* @author 倪宗锋
*/
public function getBaseUrl()
{
return $this->baseUrl;
}
/**
* Function Description:设置是否有返回值
* Function Name: setNotReturn
* @param $str
*
*
* @author 倪宗锋
*/
public function setNotReturn($str)
{
$this->notReturn = $str;
}
/**
* Function Description:设置请求报文 $body 必须是个数组
* Function Name: setBody
* @param $body
* @param $type int 1:json 2:xml 3 发送原数据接收xml 4 发送原数据 接收json 5:都是原数据
*
* @author 倪宗锋
*/
public function setBody($body, $type = 1)
{
$this->body = '';
if (is_array($body)) {
if ($type == 1) {
$this->body = json_encode($body);
$this->requestLength = strlen($this->body);
} elseif ($type == 2) {
$this->body = '<?xml version="1.0" encoding="UTF-8"?>' . Util::arraysToXml(['response' => $body]);
$this->requestLength = strlen($this->body);
} elseif (in_array($type, array(3, 4, 5))) {
$this->body = $body;
}
} else {
$this->body = $body;
}
$this->bodyType = $type;
}
/**
* Function Description:设置ssl类型
* Function Name: setCert
* @param $certArr array
*
*
* @author 倪宗锋
*/
public function setCert($certArr)
{
$this->cert = true;
$this->certPem = $certArr['SSLCERT_PATH'];
$this->keyPem = $certArr['SSLKEY_PATH'];
}
/*****************==========参数设置函数结束=========******************/
/*****************==========调用接口并返回结果===开始======******************/
/**
* Function Description:执行交易
* Function Name: execute
* @param $url string sap地址
* @param $verb string 请求方式 post|get
* @return array
* @author nizongfeng
* Modify Date:2016.11.10
*/
public function execute($url, $verb = 'GET')
{
$url = preg_replace('# #','%20',$url);
$this->verb = $verb;
$this->url = $this->baseUrl . $url;
$this->logMessage .= date('Y-m-d H:i:s') . " Url : {$this->url}";
$this->logMessage .= ' Method:' . $this->verb . PHP_EOL;
if (is_array($this->body)) {
$this->logMessage .= "sendContent: " . json_encode($this->body) . PHP_EOL;
} else {
$this->logMessage .= "sendContent: {$this->body}" . PHP_EOL;
}
$ch = curl_init($this->url);
try {
switch (strtoupper($this->verb)) {
case 'GET':
$this->executeGet($ch);
break;
case 'POST':
$this->executePost($ch);
break;
case 'PUT':
$this->executePut($ch);
break;
case 'DELETE':
$this->executeDelete($ch);
break;
default:
$this->logMessage .= "current verb: {$this->verb}, is an invalid REST verb." . PHP_EOL;
break;
}
} catch (\Exception $e) {
$this->logMessage .= $e->getMessage() . PHP_EOL;
}
curl_close($ch);
$ch = null;
return $this->getResult();
}
/**
* Function Description:获取返回数据
* Function Name: getResult
*
* @return array|mixed
*
* @author nizongfeng
* Modify Date:2016.11.10
*/
public function getResult()
{
if (in_array($this->bodyType, array(1, 4))) {
$return = json_decode($this->responseBody, true);
} elseif (in_array($this->bodyType, array(2, 3))) {
$return = Util::xmlToArray($this->responseBody);
} elseif ($this->bodyType == 5) {
$return = $this->responseBody;
} else {
$return = '';
}
// file_put_contents(APP_PATH . '/log/curl/' . date('Y-m-d') . '.log', $this->logMessage . PHP_EOL, FILE_APPEND);
return $return;
}
/*******************=====GET传值=====********************/
/**
* Function Description:GET传值
* Function Name: executeGet
* @param $ch
*
* @return void
*
* @author nizongfeng 2016.11.10
*/
protected function executeGet($ch)
{
curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, FALSE);
curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, FALSE);
curl_setopt($ch, CURLOPT_FOLLOWLOCATION, 1);
$this->doExecute($ch);
}
/*******************=====POST传值=====********************/
/**
* Function Description:POST传值
* Function Name: executePost
* @param $ch
*
* @return void
*
* @author nizongfeng 2016.11.10
*/
protected function executePost($ch)
{
// curl_setopt($ch, CURLOPT_VERBOSE, true);
curl_setopt($ch, CURLOPT_POST, true);
if (is_array($this->body)) {
$cnt = $this->getmaxdim($this->body);
if ($cnt > 1) {
curl_setopt($ch, CURLOPT_POSTFIELDS, http_build_query($this->body));
} else {
curl_setopt($ch, CURLOPT_POSTFIELDS, $this->body);
}
} else {
curl_setopt($ch, CURLOPT_POSTFIELDS, $this->body);
}
curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
curl_setopt($ch, CURLOPT_FOLLOWLOCATION, 1);
$this->doExecute($ch);
}
/*******************=====PUT传值=====********************/
/**
* Function Description:PUT传值
* Function Name: executePut
* @param $ch
*
*
* @author 倪宗锋
*/
protected function executePut($ch)
{
curl_setopt($ch, CURLOPT_CUSTOMREQUEST, 'PUT');
curl_setopt($ch, CURLOPT_POSTFIELDS, $this->body);
$this->doExecute($ch);
}
/*******************=====DELETE传值=====********************/
/**
* Function Description:DELETE传值
* Function Name: executeDelete
* @param $ch
*
*
* @author 倪宗锋
*/
protected function executeDelete($ch)
{
curl_setopt($ch, CURLOPT_POSTFIELDS, $this->body);
curl_setopt($ch, CURLOPT_CUSTOMREQUEST, 'DELETE');
$this->doExecute($ch);
}
/*******************=====传值及接收=====********************/
/**
* Function Description: 传值及接受数据
* Function Name: doExecute
* @param $curlHandle
*
* @return void
*
* @author nizongfeng 2015.12.08
*/
protected function doExecute(&$curlHandle)
{
if ($this->verb != 'get') {
$this->setCurlOpts($curlHandle);
}
curl_setopt($curlHandle, CURLOPT_HEADER, $this->curlOptHeader);
curl_setopt($curlHandle, CURLOPT_RETURNTRANSFER, true);
curl_setopt($curlHandle, CURLOPT_TIMEOUT, $this->timeOut);
//记录报文发送时间
$sendTime = microtime(true);
$this->responseBody = curl_exec($curlHandle);
//记录报文返回时间
$responseTime = microtime(true);
$timeIncrement = round(floatval($responseTime - $sendTime), 3);
//记录返回的报文信息
$this->logMessage .= "response: {$this->responseBody}" . PHP_EOL;
$curlInfo = curl_getinfo($curlHandle);
$this->curlGetInfo = $curlInfo;
if (empty($curlInfo['primary_port'])) {
$curlInfo['primary_port'] = '';
}
$curlInfoStr = '';
if (isset($_SERVER['SERVER_ADDR']) && $_SERVER['SERVER_PORT']) {
$curlInfoStr = " toIP {$curlInfo['primary_ip']}:{$curlInfo['primary_port']}";
$curlInfoStr .= " selfIP {$_SERVER['SERVER_ADDR']} {$_SERVER['SERVER_PORT']}";
}
//记录通信信息及性能指标
$this->logMessage .= "Info: " . json_encode($curlInfoStr) . PHP_EOL;
$this->logMessage .= "sendTime: " . date('H:i:s', $sendTime) . " , responseTime: ";
$this->logMessage .= date('H:i:s', $responseTime) . " , timeIncrement:" . $timeIncrement . 's'
. PHP_EOL;
$curlError = curl_error($curlHandle);
if ($curlError) {
$this->logMessage .= "Error: " . $curlError . PHP_EOL;
}
}
/*******************=====头部设置=====********************/
/**
* Function Description:头部设置
* Function Name: setCurlOpts
* @param $curlHandle
*
*
* @author 倪宗锋
*/
protected function setCurlOpts(&$curlHandle)
{
if ($this->cert == 1) {
//设置证书
//使用证书：cert 与 key 分别属于两个.pem文件
curl_setopt($curlHandle, CURLOPT_SSLCERTTYPE, 'PEM');
curl_setopt($curlHandle, CURLOPT_SSLCERT, $this->certPem);
curl_setopt($curlHandle, CURLOPT_SSLKEYTYPE, 'PEM');
curl_setopt($curlHandle, CURLOPT_SSLKEY, $this->keyPem);
}
}
/*****************==========调用接口并返回结果===结束======******************/
//获取数组是几维数组
private function getmaxdim($vDim)
{
if (!is_array($vDim)) return 0;
else {
$max1 = 0;
foreach ($vDim as $item1) {
$t1 = $this->getmaxdim($item1);
if ($t1 > $max1) $max1 = $t1;
}
return $max1 + 1;
}
}
}
?>