ECSHOP curl 代理服务器设置（用于本地调试）

Dear 丶 2024-02-17 21:14 56阅读 0赞

// 代理服务器 调试时使用代理，上线时注释掉
                curl_setopt($ci, CURLOPT_PROXY, '127.0.0.1');
                curl_setopt($ci, CURLOPT_PROXYPORT, '8087');

<?php 
 
 // HTTP 操作
 /*============================================================================
 **/
 
 if (!defined('WEBSITE'))
 {
 
 if(!function_exists('curl_init')) // 检测是否支持 curl_init
 {
 define('CURL' , false);
 if(function_exists('fsockopen')) // 检测是否支持 fsockopen
 {
 define('FSOCK' , true);
 }
 else
 {
 define('FSOCK' , false);
 }
 }
 else
 {
 define('CURL' , true);
 }
 
 
 class cls_http
 {
 
 public $error_msg = array();
 public $http_code;
 public $url;
 public $timeout = 60;
 public $connecttimeout = 30;
 public $ssl_verifypeer = FALSE;
 public $http_info;
 public static $boundary = '';
 
 
 
 function http($url, $method = 'GET', $parameters = array(), $multi = false) 
 {
 
 switch ($method) {
 case 'GET':
 if(!empty($parameters))
 {
 $url = $url . '?' . http_build_query($parameters);
 }
 return $this->httpRequest($url, 'GET');
 break;
 case 'POST':
 if(is_array($parameters))
 {
 $body = $this->get_params($parameters);
 
 echo $body ;
 }
 else
 {
 $body = $parameters;
 }
 return $this->httpRequest($url, $method, $body);
 break;
 default:
 $headers = array();
 if (!$multi && (is_array($parameters) || is_object($parameters)) ) {
 $body = http_build_query($parameters);
 } else {
 $body = self::build_http_query_multi($parameters);
 $headers[] = "Content-Type: multipart/form-data; boundary=" . self::$boundary;
 }
 return $this->httpRequest($url, $method, $body, $headers);
 break;
 }
 }
 function httpRequest($url, $method, $postfields = NULL, $headers = array()) {
 
 
 if(!CURL)
 {
 if(FSOCK)
 {
 $responseText = $this->fsockRequest($url , $method , $postfields , $headers);
 return $responseText;
 }
 return false;
 }
 
 $this->http_info = array();
 $ci = curl_init();
 /* Curl settings */
 curl_setopt($ci, CURLOPT_HTTP_VERSION, CURL_HTTP_VERSION_1_0);
 curl_setopt($ci, CURLOPT_USERAGENT, $this->useragent);
 curl_setopt($ci, CURLOPT_CONNECTTIMEOUT, $this->connecttimeout);
 curl_setopt($ci, CURLOPT_TIMEOUT, $this->timeout);
 curl_setopt($ci, CURLOPT_RETURNTRANSFER, TRUE);
 curl_setopt($ci, CURLOPT_ENCODING, "");
 curl_setopt($ci, CURLOPT_SSL_VERIFYPEER, $this->ssl_verifypeer);
 curl_setopt($ci, CURLOPT_HEADERFUNCTION, array($this, 'getHeader'));
 curl_setopt($ci, CURLOPT_HEADER, FALSE);
 
 
 switch ($method) {
 case 'POST':
 curl_setopt ( $ci, CURLOPT_POST, TRUE );
 if (!empty($postfields)) {
 curl_setopt ($ci, CURLOPT_POSTFIELDS, $postfields);
 $this->postdata = $postfields;
 }
 break;
 }
 
 $headers[] = "API-RemoteIP: " . $_SERVER['REMOTE_ADDR'];
 curl_setopt($ci, CURLOPT_URL, $url );
 curl_setopt($ci, CURLOPT_HTTPHEADER, $headers );
 curl_setopt($ci, CURLINFO_HEADER_OUT, TRUE );
 
 // 代理服务器 调试时使用代理，上线时注释掉
 curl_setopt($ci, CURLOPT_PROXY, '127.0.0.1');
 curl_setopt($ci, CURLOPT_PROXYPORT, '8087');
 
 $response = curl_exec($ci);
 
 $this->http_code = curl_getinfo($ci, CURLINFO_HTTP_CODE);
 $this->http_info = array_merge($this->http_info, curl_getinfo($ci));
 $this->url = $url;
 curl_close ($ci);
 
 return $response;
 }
 
 /**
 * Get the header info to store.
 *
 * @return int
 * @ignore
 */
 function getHeader($ch, $header) {
 
 $i = strpos($header, ':');
 if (!empty($i)) {
 $key = str_replace('-', '_', strtolower(substr($header, 0, $i)));
 $value = trim(substr($header, $i + 2));
 $this->http_header[$key] = $value;
 }
 return strlen($header);
 }
 
 /**
 * @ignore
 */
 public static function build_http_query_multi($params) {
 
 if (!$params) return '';
 uksort($params, 'strcmp');
 $pairs = array();
 
 self::$boundary = $boundary = uniqid('------------------');
 $MPboundary = '--'.$boundary;
 $endMPboundary = $MPboundary. '--';
 $multipartbody = '';
 
 foreach ($params as $parameter => $value) {
 
 if( in_array($parameter, array('pic', 'image')) && $value{
 0} == '@' ) {
 $url = ltrim( $value, '@' );
 $content = file_get_contents( $url );
 $array = explode( '?', basename( $url ) );
 $filename = $array[0];
 
 $multipartbody .= $MPboundary . "\r\n";
 $multipartbody .= 'Content-Disposition: form-data; name="' . $parameter . '"; filename="' . $filename . '"'. "\r\n";
 $multipartbody .= "Content-Type: image/unknown\r\n\r\n";
 $multipartbody .= $content. "\r\n";
 } else {
 $multipartbody .= $MPboundary . "\r\n";
 $multipartbody .= 'content-disposition: form-data; name="' . $parameter . "\"\r\n\r\n";
 $multipartbody .= $value."\r\n";
 }
 }
 $multipartbody .= $endMPboundary;
 return $multipartbody;
 }
 
 function get_params($p)
 {
 
 $str = '';
 foreach($p as $key => $val)
 {
 if(isset($str{
 1}))
 {
 $str .= '&';
 }
 $str .= $key .'='.$val;
 }
 return $str;
 }
 
 
 // NUM code
 // String message
 // String 附加错误
 function add_error($code , $message , $string ='') 
 {
 
 $this->error_msg['code'] = $code;
 $this->error_msg['message'] = $message;
 $this->error_msg['string'] = $string;
 }
 function echo_error( $str = '' )
 {
 
 echo $str ."\r\n";
 print_r( $this->error_msg );
 exit();
 }
 function get_error()
 {
 
 $string = '';
 $string .= '-code:'.$this->error_msg['code']." \r\n \r\n";
 $string .= '-message:'.$this->error_msg['message']." \r\n \r\n";
 $string .= '-Message2:'.$this->error_msg['string']." \r\n \r\n";
 return $string;
 }
 /* 模拟HTTP 提交数据
 * @param public
 * @param string $url 连接地址 
 * @param string $method 模式 只有 GET POST
 * @param string $postfields 提交的数据
 * @param array @headers 头数据
 */
 
 function fsockRequest( $url, $method, $postfields = NULL, $headers = array() )
 {
 
 $urlarr = parse_url($url);
 
 $errno = '';
 $errstr = '';
 $transports = '';
 $responseText = '';
 if($urlarr['scheme'] == 'https') {
 $transports = 'ssl://';
 $urlarr['port'] = '443';
 } else {
 $transports = 'tcp://';
 $urlarr['port'] = '80';
 }
 
 
 
 $fp = @fsockopen($transports . $urlarr['host'] , $urlarr['port'] , $errno , $errstr , $this->timeout);
 
 if(!$fp) {
 die("ERROR: $errno - ".ecs_iconv('GBK' , 'UTF8', $errstr)." \r\n");
 return false;
 } else {
 if(!empty($urlarr['query']))
 {
 $urlarr['path'] .= '?'.$urlarr['query'];
 }
 $urlarr['method'] = $method;
 //print_r($urlarr);
 
 $header = $method.' '. $urlarr['path'] ." HTTP/1.1\r\n";
 
 //fputs($fp, $method.' '. $urlarr['path'] ." HTTP/1.1\r\n");
 //fputs($fp, "Referer: " . $url ."\r\n");
 
 if($method == 'POST')
 {
 $header .= "Content-type: application/x-www-form-urlencoded\r\n";
 $header .= "Content-length: ".strlen($postfields)."\r\n";
 }
 
 $header .= "Host: ".$urlarr['host']."\r\n";
 $header .= "Connection: close\r\n\r\n";
 
 fputs($fp , $header);
 if($method == 'POST') // 发送数据
 {
 fputs($fp, $postfields . "\r\n\r\n");
 }
 
 while(!feof($fp)) {
 $responseText .= @fgets($fp, 1024);
 }
 
 fclose($fp);
 $len = 0;
 
 $pos = strpos($responseText , 'Content-Length:');
 if($pos > 0)
 {
 $pos += 15;
 $len = intval(substr($responseText , $pos , stripos($responseText , "\r\n" , $pos) - $pos));
 }
 
 $responseText = trim(stristr($responseText,"\r\n\r\n"),"\r\n");
 
 if($len > 0)
 {
 if(strlen($responseText) != $len)
 {
 $nowH = substr($responseText , 0 , strpos($responseText , "\r\n"));
 if(strlen($responseText) - strlen($nowH) + 2 == $len)
 {
 $responseText = substr($responseText , strpos($responseText , "\r\n") + 2);
 }
 }
 }
 else
 {
 $responseText = trim(substr($responseText , strpos($responseText , "\r\n") + 2) , "\r\n");
 $responseText = substr($responseText , 0 , strrpos($responseText ,"\r\n"));
 }
 return $responseText;
 }
 }
 }
 }
 ?>