@ -2,13 +2,18 @@
namespace EasyAlipay\Kernel;namespace EasyAlipay\Kernel;
use EasyAlipay\Kernel\Exceptions\BadRequestException;
use EasyAlipay\Kernel\Exceptions\InvalidArgumentException;
use EasyAlipay\Kernel\Exceptions\InvalidConfigException;use EasyAlipay\Kernel\Exceptions\InvalidConfigException;
use function EasyAlipay\Kernel\encrypt;use EasyAlipay\Kernel\Exceptions\InvalidSignException;
use EasyAlipay\Kernel\Support\Collection;
use EasyAlipay\Kernel\Traits\SingData;
use Exception;use Exception;
use EasyAlipay\Kernel\SignData;
class AopClient extends BaseClientclass AopClient extends BaseClient
{{
use SingData;
//应用ID //应用ID
private $appId; private $appId;
//商户私钥值 //商户私钥值
@ -21,19 +26,11 @@ class AopClient extends BaseClient
private $format = "json"; private $format = "json";
//签名类型 //签名类型
private $signType = "RSA"; private $signType = "RSA";
// 表单提交字符集编码
private $postCharset = "UTF-8";
//api版本 //api版本
private $apiVersion = "1.0"; private $apiVersion = "1.0";
//私钥文件路径
private $rsaPrivateKeyFilePath;
private $alipayPublicKey = null;
private $debugInfo = false; private $debugInfo = false;
private $fileCharset = "UTF-8";
private $RESPONSE_SUFFIX = "_response"; private $RESPONSE_SUFFIX = "_response";
private $ERROR_RESPONSE = "error_response"; private $ERROR_RESPONSE = "error_response";
@ -50,6 +47,11 @@ class AopClient extends BaseClient
protected $alipaySdkVersion = "alipay-sdk-php-easyalipay-20190820"; protected $alipaySdkVersion = "alipay-sdk-php-easyalipay-20190820";
/**
* AopClient constructor.
* @param ServiceContainer $app
* @throws InvalidConfigException
*/
public function __construct(ServiceContainer $app) public function __construct(ServiceContainer $app)
{ {
parent::__construct($app); parent::__construct($app);
@ -59,8 +61,7 @@ class AopClient extends BaseClient
$this->alipayrsaPublicKey = $app['config']['alipay_public_key']; $this->alipayrsaPublicKey = $app['config']['alipay_public_key'];
$this->postCharset = $app['config']['charset']; $this->postCharset = $app['config']['charset'];
$this->signType = $app['config']['sign_type']; $this->signType = $app['config']['sign_type'];
$this->gatewayUrl = $app['config']['gateway_url']; $this->encryptKey = $app['config']['encrypt_key'];
if (empty($this->appId) || trim($this->appId) == "") { if (empty($this->appId) || trim($this->appId) == "") {
throw new InvalidConfigException("appId should not be NULL!"); throw new InvalidConfigException("appId should not be NULL!");
} }
@ -70,31 +71,27 @@ class AopClient extends BaseClient
if (empty($this->alipayrsaPublicKey) || trim($this->alipayrsaPublicKey) == "") { if (empty($this->alipayrsaPublicKey) || trim($this->alipayrsaPublicKey) == "") {
throw new InvalidConfigException("alipayPublicKey should not be NULL!"); throw new InvalidConfigException("alipayPublicKey should not be NULL!");
} }
if (empty($this->postCharset) || trim($this->postCharset) == "") {
throw new InvalidConfigException("postCharset should not be NULL!");
}
if (empty($this->signType) || trim($this->signType) == "") { if (empty($this->signType) || trim($this->signType) == "") {
throw new InvalidConfigException("signType should not be NULL!"); throw new InvalidConfigException("signType should not be NULL!");
} }
if (empty($this->gatewayUrl) || trim($this->gatewayUrl) == "") {
throw new InvalidConfigException("gatewayUrl should not be NULL!");
}
} }
/** /**
* @param AopRequest $request * @param AopRequest $request
* @param null $authToken * @param null $authToken
* @param null $appInfoAuthtoken * @param null $appInfoAuthtoken
* @return bool|mixed|\SimpleXMLElement * @return Collection
* @throws BadRequestException
* @throws InvalidArgumentException
* @throws InvalidConfigException
* @throws InvalidSignException
* @throws \GuzzleHttp\Exception\GuzzleException * @throws \GuzzleHttp\Exception\GuzzleException
*/ */
public function execute(AopRequest $request, $authToken = null, $appInfoAuthtoken = null) public function execute(AopRequest $request, $authToken = null, $appInfoAuthtoken = null)
{ {
$this->setupCharsets($request); $this->setupCharsets($request);
//如果两者编码不一致，会出现签名验签或者乱码
if (strcasecmp($this->fileCharset, $this->postCharset)) { if (strcasecmp($this->fileCharset, $this->postCharset)) {
// writeLog("本地文件字符集编码与表单提交编码不一致，请务必设置成一样，属性名分别为postCharset!"); throw new InvalidConfigException("文件编码：[" . $this->fileCharset . "] 与表单提交编码：[" . $this->postCharset . "]两者不一致!");
throw new Exception("文件编码：[" . $this->fileCharset . "] 与表单提交编码：[" . $this->postCharset . "]两者不一致!");
} }
$iv = null; $iv = null;
if (!$this->checkEmpty($request->getApiVersion())) { if (!$this->checkEmpty($request->getApiVersion())) {
@ -102,7 +99,6 @@ class AopClient extends BaseClient
} else { } else {
$iv = $this->apiVersion; $iv = $this->apiVersion;
} }
//组装系统参数
$sysParams["app_id"] = $this->appId; $sysParams["app_id"] = $this->appId;
$sysParams["version"] = $iv; $sysParams["version"] = $iv;
$sysParams["format"] = $this->format; $sysParams["format"] = $this->format;
@ -122,13 +118,13 @@ class AopClient extends BaseClient
if (method_exists($request, "getNeedEncrypt") & & $request->getNeedEncrypt()) { if (method_exists($request, "getNeedEncrypt") & & $request->getNeedEncrypt()) {
$sysParams["encrypt_type"] = $this->encryptType; $sysParams["encrypt_type"] = $this->encryptType;
if ($this->checkEmpty($apiParams['biz_content'])) { if ($this->checkEmpty($apiParams['biz_content'])) {
throw new Exception(" api request Fail! The reason : encrypt request is not supperted!"); throw new InvalidArgument Exception(" api request Fail! The reason : encrypt request is not supperted!");
} }
if ($this->checkEmpty($this->encryptKey) || $this->checkEmpty($this->encryptType)) { if ($this->checkEmpty($this->encryptKey) || $this->checkEmpty($this->encryptType)) {
throw new Exception(" encryptType and encryptKey must not null! "); throw new InvalidArgument Exception(" encryptType and encryptKey must not null! ");
} }
if ("AES" != $this->encryptType) { if ("AES" != $this->encryptType) {
throw new Exception("加密类型只支持AES"); throw new InvalidArgument Exception("加密类型只支持AES");
} }
// 执行加密 // 执行加密
$enCryptContent = encrypt($apiParams['biz_content'], $this->encryptKey); $enCryptContent = encrypt($apiParams['biz_content'], $this->encryptKey);
@ -136,401 +132,53 @@ class AopClient extends BaseClient
} }
//签名 //签名
$sysParams["sign"] = $this->generateSign(array_merge($apiParams, $sysParams), $this->signType); $sysParams["sign"] = $this->generateSign(array_merge($apiParams, $sysParams), $this->signType);
//系统参数放入GET请求串 $requestUrl = $this->buildRequestUrl($sysParams);
$requestUrl = $this->gatewayUrl . "?"; $result = $this->httpPost($requestUrl, $apiParams);
foreach ($sysParams as $sysParamKey => $sysParamValue) { $apiName = $request->getApiMethodName();
$requestUrl .= "$sysParamKey=" . urlencode($this->characet($sysParamValue, $this->postCharset)) . "&"; $method = str_replace(".", "_", $apiName) . $this->RESPONSE_SUFFIX;
} if (!isset($result[$this->SIGN_NODE_NAME]) || $result[$method]['code'] != '10000') {
$requestUrl = substr($requestUrl, 0, -1); throw new BadRequestException(
//发起HTTP请求 'Get Alipay API Error:' . $result[$method]['msg'] .
try { (isset($result[$method]['sub_code']) ? (' - ' . $result[$method]['sub_code']) : '')
$resp = $this->httpPost($requestUrl, $apiParams); );
var_dump($resp);die;
} catch (Exception $e) {
var_dump($e->getMessage());die;
return false;
}
//解析AOP返回结果
$respWellFormed = false;
// 将返回结果转换本地文件编码
// $r = iconv($this->postCharset, $this->fileCharset . "//IGNORE", $resp);
$signData = null;
if ("json" == $this->format) {
$respObject = $resp;
if (null !== $respObject) {
$respWellFormed = true;
$signData = $this->parserJSONSignData($request, $resp, $respObject);
var_dump($signData);die;
}
} else if ("xml" == $this->format) {
$disableLibxmlEntityLoader = libxml_disable_entity_loader(true);
$respObject = @ simplexml_load_string($resp);
if (false !== $respObject) {
$respWellFormed = true;
$signData = $this->parserXMLSignData($request, $resp);
}
libxml_disable_entity_loader($disableLibxmlEntityLoader);
}
//返回的HTTP文本不是标准JSON或者XML，记下错误日志
if (false === $respWellFormed) {
return false;
}
// 验签
$this->checkResponseSign($request, $signData, $resp, $respObject);
// 解密
if (method_exists($request, "getNeedEncrypt") & & $request->getNeedEncrypt()) {
if ("json" == $this->format) {
$resp = $this->encryptJSONSignSource($request, $resp);
// 将返回结果转换本地文件编码
$r = iconv($this->postCharset, $this->fileCharset . "//IGNORE", $resp);
$respObject = json_decode($r);
} else {
$resp = $this->encryptXMLSignSource($request, $resp);
$r = iconv($this->postCharset, $this->fileCharset . "//IGNORE", $resp);
$disableLibxmlEntityLoader = libxml_disable_entity_loader(true);
$respObject = @ simplexml_load_string($r);
libxml_disable_entity_loader($disableLibxmlEntityLoader);
}
}
return $respObject;
}
public function generateSign($params, $signType = "RSA")
{
return $this->sign($this->getSignContent($params), $signType);
}
public function getSignContent($params)
{
ksort($params);
$stringToBeSigned = "";
$i = 0;
foreach ($params as $k => $v) {
if (false === $this->checkEmpty($v) & & "@" != substr($v, 0, 1)) {
// 转换成目标字符集
$v = $this->characet($v, $this->postCharset);
if ($i == 0) {
$stringToBeSigned .= "$k" . "=" . "$v";
} else {
$stringToBeSigned .= "& " . "$k" . "=" . "$v";
}
$i++;
}
}
unset ($k, $v);
return $stringToBeSigned;
}
protected function sign($data, $signType = "RSA")
{
if ($this->checkEmpty($this->rsaPrivateKeyFilePath)) {
$priKey = $this->rsaPrivateKey;
$res = "-----BEGIN RSA PRIVATE KEY-----\n" .
wordwrap($priKey, 64, "\n", true) .
"\n-----END RSA PRIVATE KEY-----";
} else {
$priKey = file_get_contents($this->rsaPrivateKeyFilePath);
$res = openssl_get_privatekey($priKey);
}
($res) or die('您使用的私钥格式错误，请检查RSA私钥配置');
if ("RSA2" == $signType) {
openssl_sign($data, $sign, $res, OPENSSL_ALGO_SHA256);
} else {
openssl_sign($data, $sign, $res);
}
if (!$this->checkEmpty($this->rsaPrivateKeyFilePath)) {
openssl_free_key($res);
}
$sign = base64_encode($sign);
return $sign;
}
protected function curl($url, $postFields = null)
{
$ch = curl_init();
curl_setopt($ch, CURLOPT_URL, $url);
curl_setopt($ch, CURLOPT_FAILONERROR, false);
curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, true);
$postBodyString = "";
$encodeArray = Array();
$postMultipart = false;
if (is_array($postFields) & & 0 < count ( $ postFields ) ) {
foreach ($postFields as $k => $v) {
if ("@" != substr($v, 0, 1)) //判断是不是文件上传
{
$postBodyString .= "$k=" . urlencode($this->characet($v, $this->postCharset)) . "&";
$encodeArray[$k] = $this->characet($v, $this->postCharset);
} else //文件上传用multipart/form-data，否则用www-form-urlencoded
{
$postMultipart = true;
$encodeArray[$k] = new \CURLFile(substr($v, 1));
}
}
unset ($k, $v);
curl_setopt($ch, CURLOPT_POST, true);
if ($postMultipart) {
curl_setopt($ch, CURLOPT_POSTFIELDS, $encodeArray);
} else {
curl_setopt($ch, CURLOPT_POSTFIELDS, substr($postBodyString, 0, -1));
}
}
if ($postMultipart) {
$headers = array('content-type: multipart/form-data;charset=' . $this->postCharset . ';boundary=' . $this->getMillisecond());
} else {
$headers = array('content-type: application/x-www-form-urlencoded;charset=' . $this->postCharset);
}
curl_setopt($ch, CURLOPT_HTTPHEADER, $headers);
$reponse = curl_exec($ch);
if (curl_errno($ch)) {
throw new Exception(curl_error($ch), 0);
} else {
$httpStatusCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
if (200 !== $httpStatusCode) {
throw new Exception($reponse, $httpStatusCode);
}
} }
curl_close($ch); if (!$this->verify($result[$method], $result[$this->SIGN_NODE_NAME], $this->alipayrsaPublicKey, $this->signType)) {
return $reponse ; throw new InvalidSignException('签名失败');
} }
return new Collection($result[$method]);
protected function getMillisecond()
{
list($s1, $s2) = explode(' ', microtime());
return (float)sprintf('%.0f', (floatval($s1) + floatval($s2)) * 1000);
} }
/** /**
* 转换字符集编码 * 构造请求url
* @param $data * @param $sysParams
* @param $targetCharset * @return false|string
* @return string
*/ */
function characet($data, $targetCharset ) public function buildRequestUrl($sysParams)
{ {
if (!empty($data)) { $requestUrl = $this->gatewayUrl . "?";
$fileType = $this->fileCharset; foreach ($sysParams as $sysParamKey => $sysParamValue) {
if (strcasecmp($fileType, $targetCharset) != 0) { $requestUrl .= "$sysParamKey=" . urlencode($this->characet($sysParamValue, $this->postCharset)) . "&";
$data = mb_convert_encoding($data, $targetCharset, $fileType);
// $data = iconv($fileType, $targetCharset.'//IGNORE', $data);
}
} }
return $data; $requestUrl = substr($requestUrl, 0, -1);
return $requestUrl;
} }
/** /**
* 校验$value是否非空 * 获取签名数据
* if not set ,return true; * @param $params
* if is null , return true; * @param string $signType
**/ * @return string
protected function checkEmpty($value) * @throws InvalidConfigException
{ */
if (!isset($value)) public function generateSign($params, $signType = "RSA")
return true;
if ($value === null)
return true;
if (trim($value) === "")
return true;
return false;
}
public function rsaCheckV2($params, $rsaPublicKeyFilePath, $signType = 'RSA')
{
$sign = $params['sign'];
$params['sign'] = null;
return $this->verify($this->getSignContent($params), $sign, $rsaPublicKeyFilePath, $signType);
}
function verify($data, $sign, $rsaPublicKeyFilePath, $signType = 'RSA')
{
if ($this->checkEmpty($this->alipayPublicKey)) {
$pubKey = $this->alipayrsaPublicKey;
$res = "-----BEGIN PUBLIC KEY-----\n" .
wordwrap($pubKey, 64, "\n", true) .
"\n-----END PUBLIC KEY-----";
} else {
//读取公钥文件
$pubKey = file_get_contents($rsaPublicKeyFilePath);
//转换为openssl格式密钥
$res = openssl_get_publickey($pubKey);
}
($res) or die('支付宝RSA公钥错误。请检查公钥文件格式是否正确');
//调用openssl内置方法验签，返回bool值
$result = FALSE;
if ("RSA2" == $signType) {
$result = (openssl_verify($data, base64_decode($sign), $res, OPENSSL_ALGO_SHA256) === 1);
} else {
$result = (openssl_verify($data, base64_decode($sign), $res) === 1);
}
if (!$this->checkEmpty($this->alipayPublicKey)) {
//释放资源
openssl_free_key($res);
}
return $result;
}
function parserResponseSubCode($request, $responseContent, $respObject, $format)
{
if ("json" == $format) {
$apiName = $request->getApiMethodName();
$rootNodeName = str_replace(".", "_", $apiName) . $this->RESPONSE_SUFFIX;
$errorNodeName = $this->ERROR_RESPONSE;
$rootIndex = strpos($responseContent, $rootNodeName);
$errorIndex = strpos($responseContent, $errorNodeName);
if ($rootIndex > 0) {
// 内部节点对象
$rInnerObject = $respObject->$rootNodeName;
} elseif ($errorIndex > 0) {
$rInnerObject = $respObject->$errorNodeName;
} else {
return null;
}
// 存在属性则返回对应值
if (isset($rInnerObject->sub_code)) {
return $rInnerObject->sub_code;
} else {
return null;
}
} elseif ("xml" == $format) {
// xml格式sub_code在同一层级
return $respObject->sub_code;
}
}
function parserJSONSignData($request, $responseContent, $responseJSON)
{
$signData = new SignData();
$signData->sign = $this->parserJSONSign($responseJSON);
$signData->signSourceData = $this->parserJSONSignSource($request, $responseContent);
return $signData;
}
function parserJSONSignSource($request, $responseContent)
{
$apiName = $request->getApiMethodName();
$rootNodeName = str_replace(".", "_", $apiName) . $this->RESPONSE_SUFFIX;
$rootIndex = strpos($responseContent, $rootNodeName);
$errorIndex = strpos($responseContent, $this->ERROR_RESPONSE);
if ($rootIndex > 0) {
return $this->parserJSONSource($responseContent, $rootNodeName, $rootIndex);
} else if ($errorIndex > 0) {
return $this->parserJSONSource($responseContent, $this->ERROR_RESPONSE, $errorIndex);
} else {
return null;
}
}
function parserJSONSource($responseContent, $nodeName, $nodeIndex)
{
$signDataStartIndex = $nodeIndex + strlen($nodeName) + 2;
$signIndex = strrpos($responseContent, "\"" . $this->SIGN_NODE_NAME . "\"");
// 签名前-逗号
$signDataEndIndex = $signIndex - 1;
$indexLen = $signDataEndIndex - $signDataStartIndex;
if ($indexLen < 0 ) {
return null;
}
return substr($responseContent, $signDataStartIndex, $indexLen);
}
function parserJSONSign($responseJSon)
{
return $responseJSon->sign;
}
function parserXMLSignData($request, $responseContent)
{
$signData = new SignData();
$signData->sign = $this->parserXMLSign($responseContent);
$signData->signSourceData = $this->parserXMLSignSource($request, $responseContent);
return $signData;
}
function parserXMLSignSource($request, $responseContent)
{
$apiName = $request->getApiMethodName();
$rootNodeName = str_replace(".", "_", $apiName) . $this->RESPONSE_SUFFIX;
$rootIndex = strpos($responseContent, $rootNodeName);
$errorIndex = strpos($responseContent, $this->ERROR_RESPONSE);
if ($rootIndex > 0) {
return $this->parserXMLSource($responseContent, $rootNodeName, $rootIndex);
} else if ($errorIndex > 0) {
return $this->parserXMLSource($responseContent, $this->ERROR_RESPONSE, $errorIndex);
} else {
return null;
}
}
function parserXMLSource($responseContent, $nodeName, $nodeIndex)
{
$signDataStartIndex = $nodeIndex + strlen($nodeName) + 1;
$signIndex = strrpos($responseContent, "< " . $this->SIGN_NODE_NAME . ">");
// 签名前-逗号
$signDataEndIndex = $signIndex - 1;
$indexLen = $signDataEndIndex - $signDataStartIndex + 1;
if ($indexLen < 0 ) {
return null;
}
return substr($responseContent, $signDataStartIndex, $indexLen);
}
function parserXMLSign($responseContent)
{ {
$signNodeName = "< " . $this->SIGN_NODE_NAME . ">"; return $this->sign($this->getSignContent($params), $this->rsaPrivateKey, $signType);
$signEndNodeName = "< /" . $this->SIGN_NODE_NAME . ">";
$indexOfSignNode = strpos($responseContent, $signNodeName);
$indexOfSignEndNode = strpos($responseContent, $signEndNodeName);
if ($indexOfSignNode < 0 | | $ indexOfSignEndNode < 0 ) {
return null;
}
$nodeIndex = ($indexOfSignNode + strlen($signNodeName));
$indexLen = $indexOfSignEndNode - $nodeIndex;
if ($indexLen < 0 ) {
return null;
}
// 签名
return substr($responseContent, $nodeIndex, $indexLen);
} }
/** /**
* 验签 * @param AopRequest $request
* @param $request
* @param $signData
* @param $resp
* @param $respObject
* @throws Exception
*/ */
public function checkResponseSign(AopRequest $request, $signData, $resp, $respObject) private function setupCharsets(AopRequest $request)
{
if (!$this->checkEmpty($this->alipayPublicKey) || !$this->checkEmpty($this->alipayrsaPublicKey)) {
if ($signData == null || $this->checkEmpty($signData->sign) || $this->checkEmpty($signData->signSourceData)) {
throw new Exception(" check sign Fail! The reason : signData is Empty");
}
// 获取结果sub_code
$responseSubCode = $this->parserResponseSubCode($request, $resp, $respObject, $this->format);
if (!$this->checkEmpty($responseSubCode) || ($this->checkEmpty($responseSubCode) & & !$this->checkEmpty($signData->sign))) {
$checkResult = $this->verify($signData->signSourceData, $signData->sign, $this->alipayPublicKey, $this->signType);
if (!$checkResult) {
if (strpos($signData->signSourceData, "\\/") > 0) {
$signData->signSourceData = str_replace("\\/", "/", $signData->signSourceData);
$checkResult = $this->verify($signData->signSourceData, $signData->sign, $this->alipayPublicKey, $this->signType);
if (!$checkResult) {
throw new Exception("check sign Fail! [sign=" . $signData->sign . ", signSourceData=" . $signData->signSourceData . "]");
}
} else {
throw new Exception("check sign Fail! [sign=" . $signData->sign . ", signSourceData=" . $signData->signSourceData . "]");
}
}
}
}
}
private function setupCharsets($request)
{ {
if ($this->checkEmpty($this->postCharset)) { if ($this->checkEmpty($this->postCharset)) {
$this->postCharset = 'UTF-8'; $this->postCharset = 'UTF-8';
@ -538,108 +186,4 @@ class AopClient extends BaseClient
$str = preg_match('/[\x80-\xff]/', $this->appId) ? $this->appId : print_r($request, true); $str = preg_match('/[\x80-\xff]/', $this->appId) ? $this->appId : print_r($request, true);
$this->fileCharset = mb_detect_encoding($str, "UTF-8, GBK") == 'UTF-8' ? 'UTF-8' : 'GBK'; $this->fileCharset = mb_detect_encoding($str, "UTF-8, GBK") == 'UTF-8' ? 'UTF-8' : 'GBK';
} }
// 获取加密内容
private function encryptJSONSignSource($request, $responseContent)
{
$parsetItem = $this->parserEncryptJSONSignSource($request, $responseContent);
$bodyIndexContent = substr($responseContent, 0, $parsetItem->startIndex);
$bodyEndContent = substr($responseContent, $parsetItem->endIndex, strlen($responseContent) + 1 - $parsetItem->endIndex);
$bizContent = decrypt($parsetItem->encryptContent, $this->encryptKey);
return $bodyIndexContent . $bizContent . $bodyEndContent;
}
private function parserEncryptJSONSignSource($request, $responseContent)
{
$apiName = $request->getApiMethodName();
$rootNodeName = str_replace(".", "_", $apiName) . $this->RESPONSE_SUFFIX;
$rootIndex = strpos($responseContent, $rootNodeName);
$errorIndex = strpos($responseContent, $this->ERROR_RESPONSE);
if ($rootIndex > 0) {
return $this->parserEncryptJSONItem($responseContent, $rootNodeName, $rootIndex);
} else if ($errorIndex > 0) {
return $this->parserEncryptJSONItem($responseContent, $this->ERROR_RESPONSE, $errorIndex);
} else {
return null;
}
}
private function parserEncryptJSONItem($responseContent, $nodeName, $nodeIndex)
{
$signDataStartIndex = $nodeIndex + strlen($nodeName) + 2;
$signIndex = strpos($responseContent, "\"" . $this->SIGN_NODE_NAME . "\"");
// 签名前-逗号
$signDataEndIndex = $signIndex - 1;
if ($signDataEndIndex < 0 ) {
$signDataEndIndex = strlen($responseContent) - 1;
}
$indexLen = $signDataEndIndex - $signDataStartIndex;
$encContent = substr($responseContent, $signDataStartIndex + 1, $indexLen - 2);
$encryptParseItem = new EncryptParseItem();
$encryptParseItem->encryptContent = $encContent;
$encryptParseItem->startIndex = $signDataStartIndex;
$encryptParseItem->endIndex = $signDataEndIndex;
return $encryptParseItem;
}
// 获取加密内容
private function encryptXMLSignSource($request, $responseContent)
{
$parsetItem = $this->parserEncryptXMLSignSource($request, $responseContent);
$bodyIndexContent = substr($responseContent, 0, $parsetItem->startIndex);
$bodyEndContent = substr($responseContent, $parsetItem->endIndex, strlen($responseContent) + 1 - $parsetItem->endIndex);
$bizContent = decrypt($parsetItem->encryptContent, $this->encryptKey);
return $bodyIndexContent . $bizContent . $bodyEndContent;
}
private function parserEncryptXMLSignSource($request, $responseContent)
{
$apiName = $request->getApiMethodName();
$rootNodeName = str_replace(".", "_", $apiName) . $this->RESPONSE_SUFFIX;
$rootIndex = strpos($responseContent, $rootNodeName);
$errorIndex = strpos($responseContent, $this->ERROR_RESPONSE);
if ($rootIndex > 0) {
return $this->parserEncryptXMLItem($responseContent, $rootNodeName, $rootIndex);
} else if ($errorIndex > 0) {
return $this->parserEncryptXMLItem($responseContent, $this->ERROR_RESPONSE, $errorIndex);
} else {
return null;
}
}
private function parserEncryptXMLItem($responseContent, $nodeName, $nodeIndex)
{
$signDataStartIndex = $nodeIndex + strlen($nodeName) + 1;
$xmlStartNode = "< " . $this->ENCRYPT_XML_NODE_NAME . ">";
$xmlEndNode = "< /" . $this->ENCRYPT_XML_NODE_NAME . ">";
$indexOfXmlNode = strpos($responseContent, $xmlEndNode);
if ($indexOfXmlNode < 0 ) {
$item = new EncryptParseItem();
$item->encryptContent = null;
$item->startIndex = 0;
$item->endIndex = 0;
return $item;
}
$startIndex = $signDataStartIndex + strlen($xmlStartNode);
$bizContentLen = $indexOfXmlNode - $startIndex;
$bizContent = substr($responseContent, $startIndex, $bizContentLen);
$encryptParseItem = new EncryptParseItem();
$encryptParseItem->encryptContent = $bizContent;
$encryptParseItem->startIndex = $signDataStartIndex;
$encryptParseItem->endIndex = $indexOfXmlNode + strlen($xmlEndNode);
return $encryptParseItem;
}
function echoDebug($content)
{
if ($this->debugInfo) {
echo "< br / > " . $content;
}
}
}}
