mall/utils/Ocr/Util/HttpUtil.php

<?php
/**
 * 重庆赤晓店信息科技有限公司
 * https://www.chixiaodian.com
 * Copyright (c) 2023 赤店商城 All rights reserved.
 */
namespace app\utils\Ocr\Util;
/*
 * Licensed to the Apache Software Foundation (ASF) under one
 * or more contributor license agreements.  See the NOTICE file
 * distributed with this work for additional information
 * regarding copyright ownership.  The ASF licenses this file
 * to you under the Apache License, Version 2.0 (the
 * "License"); you may not use this file except in compliance
 * with the License.  You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing,
 * software distributed under the License is distributed on an
 * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
 * KIND, either express or implied.  See the License for the
 * specific language governing permissions and limitations
 * under the License.
 */

use app\utils\Ocr\Constant\HttpSchema;
use app\utils\Ocr\Constant\SystemHeader;
use app\utils\Ocr\Http\HttpResponse;


/**
*http请求处理
*/
class HttpUtil 
{
	public static function send($request, $readtimeout, $connectTimeout)
    {
		return self::DoHttp($request->getHost(), 
							$request->getPath(),
							$request->getMethod(), 
							$request->getAppKey(), 
							$request->getAppSecret(), 
							$readtimeout, 
							$connectTimeout,
							$request->getHeaders(), 
							$request->getQuerys(), 
							$request->getBodys(), 
							$request->getSignHeaders());
	}

	/**
	 *请求Request
	 */
	private static function DoHttp($host, $path, $method, $appKey, $appSecret, $readtimeout, $connectTimeout, $headers, $querys, $bodys, $signHeaderPrefixList)
    {
		$response = new HttpResponse();
		$headers = self::InitialBasicHeader($path, $appKey, $appSecret, $method, $headers, $querys, $bodys, $signHeaderPrefixList);
        $curl = self::InitHttpRequest($host, $path, $method, $readtimeout, $connectTimeout, $headers, $querys);

		$streams = array();
		if (is_array($bodys)) {
			if (0 < count($bodys)) {
				$body = "";
				foreach ($bodys as $itemKey => $itemValue) {
					if (0 < strlen($body)) {
						$body .= "&";
					}
					if (0 < strlen($itemValue) && 0 == strlen($itemKey))
					{						
						$body .= $itemValue;
						array_push($streams, $itemValue);
					}
					if (0 < strlen($itemKey)) {
						$body .= "=";
						if (0 < strlen($itemValue)) {
							$body .= URLEncode($itemValue);
						}
					}
				}
				if (count($bodys) == count($streams) && 1 == count($streams)) {
					curl_setopt($curl, CURLOPT_POSTFIELDS, $streams[0]);
				} elseif (0 < count($bodys)) {
					curl_setopt($curl, CURLOPT_POSTFIELDS, http_build_query($bodys));
				}
			}		
		}
		$response->setContent(curl_exec($curl));
		$response->setHttpStatusCode(curl_getinfo($curl, CURLINFO_HTTP_CODE));
		$response->setContentType(curl_getinfo($curl, CURLINFO_CONTENT_TYPE));
		$response->setHeaderSize(curl_getinfo($curl, CURLINFO_HEADER_SIZE));		
		curl_close($curl);
		return $response;
    }

	/**
	 *准备请求Request
	 */
	private static function InitHttpRequest($host, $path, $method, $readtimeout, $connectTimeout, $headers, $querys)
	{
		$url = $host;
		if (0 < strlen($path)) {
			$url.= $path;
		}
		$headerArray = array();
		if (is_array($headers)) {
			if (0 < count($headers)) {
				foreach ($headers as $itemKey => $itemValue) {
					if (0 < strlen($itemKey)) {
						array_push($headerArray, $itemKey.":".$itemValue);
					}
				}
			}
		}
		if (is_array($querys)) {
			if (0 < count($querys)) {
				$sb = "";
				foreach ($querys as $itemKey => $itemValue) {
					if (0 < strlen($sb)) {
						$sb .= "&";
					}
					if (0 < strlen($itemValue) && 0 == strlen($itemKey))
                    {
						$sb .= $itemValue;
                    }
					if (0 < strlen($itemKey)) {
						$sb .= $itemKey;
						if (0 < strlen($itemValue)) {
							$sb .= "=";
							$sb .= URLEncode($itemValue);
						}
					}
				}
				$url .= "?";
				$url .= $sb;
			}
		}
		
		$curl = curl_init();
		curl_setopt($curl, CURLOPT_CUSTOMREQUEST, $method);
		curl_setopt($curl, CURLOPT_URL, $url);
		curl_setopt($curl, CURLOPT_HTTPHEADER, $headerArray);
		curl_setopt($curl, CURLOPT_FAILONERROR, false);
		curl_setopt($curl, CURLOPT_RETURNTRANSFER, true);
		curl_setopt($curl, CURLOPT_TIMEOUT, $readtimeout);
		curl_setopt($curl, CURLOPT_CONNECTTIMEOUT, $connectTimeout);
		curl_setopt($curl, CURLOPT_HEADER, true);

		if (1 == strpos("$".$host, HttpSchema::HTTPS))
		{
            curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, false);
			curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, false);
        }
		curl_setopt($curl, CURLOPT_HEADER, true);
        return $curl;
	}

	/**
	 *准备请求的基本header
	 */
	private static function InitialBasicHeader($path, $appKey, $appSecret, $method, $headers, $querys, $bodys, $signHeaderPrefixList) 
	{
		if (null == $headers) {
			$headers = array();
		}
		$sb = "";
		//时间戳
		date_default_timezone_set('PRC');
		$headers[SystemHeader::X_CA_TIMESTAMP] = strval(time()*1000);
		//防重放，协议层不能进行重试，否则会报NONCE被使用；如果需要协议层重试，请注释此行
		$headers[SystemHeader::X_CA_NONCE] = strval(self::NewGuid());

		$headers[SystemHeader::X_CA_KEY] = $appKey;
		$headers[SystemHeader::X_CA_SIGNATURE] = SignUtil::Sign($path, $method, $appSecret, $headers, $querys, $bodys, $signHeaderPrefixList);

		return $headers;
	}
  
	public static function CheckValidationResult($sender, $certificate, $chain, $errors)
	{
		return true;
	}

	private static function NewGuid()
	{
		mt_srand((double)microtime()*10000);
        $uuid = strtoupper(md5(uniqid(rand(), true)));
        return $uuid;        
    }
}