255 lines
9.7 KiB
PHP
255 lines
9.7 KiB
PHP
<?php
|
||
|
||
namespace Yzh;
|
||
|
||
use Yzh\Exception\ConfigException;
|
||
use Yzh\Exception\ExceptionCode;
|
||
use Yzh\Exception\HttpException;
|
||
use Yzh\Config;
|
||
use Yzh\Utils\Rsa;
|
||
use Yzh\Utils\Des;
|
||
use Yzh\Utils\Hmac;
|
||
use Yzh\Utils\MessString;
|
||
use Yzh\Model\BaseResponse;
|
||
|
||
defined("JSON_UNESCAPED_UNICODE") or define("JSON_UNESCAPED_UNICODE", 256);
|
||
|
||
class BaseClient
|
||
{
|
||
const SDK_NAME = "yunzhanghu-sdk-php";
|
||
const SDK_VERSION = "2.0.15";
|
||
const ENV_PROD = "yzh_env_prod";
|
||
const ENV_SANDBOX = "yzh_env_sandbox";
|
||
|
||
protected $env;
|
||
/**
|
||
* @var Config
|
||
*/
|
||
protected $config;
|
||
protected static $service_name;
|
||
|
||
protected static $env_service_host_map = array(
|
||
self::ENV_PROD => array( // 正式环境
|
||
'payment' => 'https://api-service.yunzhanghu.com', // 实时支付服务接口域名
|
||
'tax' => 'https://api-service.yunzhanghu.com',
|
||
'authentication' => 'https://api-service.yunzhanghu.com',
|
||
'invoice' => 'https://api-service.yunzhanghu.com',
|
||
'dataservice' => 'https://api-service.yunzhanghu.com', // 数据服务接口域名
|
||
'apiusersignservice' => 'https://api-service.yunzhanghu.com', // API 用户签约接口域名
|
||
'h5usersignservice' => 'https://api-service.yunzhanghu.com', // H5 用户签约接口域名
|
||
'uploadusersignservice' => 'https://api-service.yunzhanghu.com', // 用户签约信息上传接口域名
|
||
'bizlicgxv2h5apiservice' => 'https://api-aic.yunzhanghu.com', // 个体工商户注册服务（共享大额 H5+API）接口域名
|
||
'bizlicgxv2h5service' => 'https://api-aic.yunzhanghu.com', // 个体工商户注册服务（共享大额 H5）接口域名
|
||
'bizlicxjjh5apiservice' => 'https://api-aic.yunzhanghu.com', // 个体工商户注册服务 (云账户新经济 H5+API）接口域名
|
||
'bizlicxjjh5service' => 'https://api-aic.yunzhanghu.com', // 个体工商户注册服务（云账户新经济 H5）接口域名
|
||
'ins' => 'https://api-ins.yunzhanghu.com', // 保险服务接口域名
|
||
'task' => 'https://api-task.yunzhanghu.com', // 任务库服务接口域名
|
||
|
||
),
|
||
self::ENV_SANDBOX => array( // 沙箱环境
|
||
'payment' => 'https://api-service.yunzhanghu.com/sandbox', // 实时支付服务接口域名
|
||
'authentication' => 'https://api-service.yunzhanghu.com/sandbox', // 用户信息验证接口域名
|
||
'apiusersignservice' => 'https://api-service.yunzhanghu.com/sandbox', // API 签约接口域名
|
||
'h5usersignservice' => 'https://api-service.yunzhanghu.com/sandbox', // H5 签约接口域名
|
||
'ins' => '', // 保险服务接口域名
|
||
'aic' => '', // 个体工商户注册服务接口域名
|
||
'task' => '', // 任务库服务接口域名
|
||
'dataservice' => '', // 数据服务接口域名
|
||
),
|
||
);
|
||
|
||
protected $rsa;
|
||
protected $hmac;
|
||
protected $des;
|
||
protected $app_key;
|
||
protected $sign_type;
|
||
|
||
public function __construct($config)
|
||
{
|
||
if (!$config instanceof Config) {
|
||
throw new ConfigException('config 参数必须是 Yzh\\Config 实例', ExceptionCode::CONFIG_ERROR_WRONG_PARAM);
|
||
}
|
||
$this->config = $config;
|
||
$this->setEnv($config->env);
|
||
|
||
if ($this->config->sign_type == Config::SIGN_TYPE_RSA) {
|
||
$this->rsa = new Rsa($this->config->app_private_key, $this->config->yzh_public_key);
|
||
$this->sign_type = Config::SIGN_TYPE_RSA;
|
||
} else if ($this->config->sign_type == Config::SIGN_TYPE_HMAC) {
|
||
$this->hmac = new Hmac($this->config->app_key);
|
||
$this->sign_type = Config::SIGN_TYPE_HMAC;
|
||
} else {
|
||
throw new ConfigException("签名方式配置错误", ExceptionCode::CONFIG_ERROR_WRONG_SIGN_TYPE);
|
||
}
|
||
|
||
$this->app_key = $this->config->app_key;
|
||
$this->des = new Des($this->config->app_des3_key);
|
||
}
|
||
|
||
public function setEnv($envName)
|
||
{
|
||
if (!in_array($envName, array(self::ENV_PROD, self::ENV_SANDBOX), true)) {
|
||
throw new ConfigException("请选择正确的服务环境", ExceptionCode::CONFIG_ERROR_WRONG_ENV);
|
||
}
|
||
$this->env = $envName;
|
||
return $this;
|
||
}
|
||
|
||
protected function get($url, $data, $header, $option)
|
||
{
|
||
$curl = curl_init();
|
||
|
||
curl_setopt_array($curl, array(
|
||
CURLOPT_URL => $url . '?' . http_build_query($data),
|
||
CURLOPT_RETURNTRANSFER => true,
|
||
CURLOPT_CONNECTTIMEOUT => $option->getConnectTimeout(),
|
||
CURLOPT_TIMEOUT => $option->getTimeout(),
|
||
CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
|
||
CURLOPT_CUSTOMREQUEST => 'GET',
|
||
CURLOPT_HTTPHEADER => $header,
|
||
));
|
||
|
||
$response = curl_exec($curl);
|
||
|
||
if ($response == false) {
|
||
$errMsg = curl_error($curl);
|
||
curl_close($curl);
|
||
throw new HttpException("请求失败,response:" . $errMsg, 0);
|
||
}
|
||
|
||
$curlInfo = curl_getinfo($curl);
|
||
curl_close($curl);
|
||
|
||
if ($curlInfo['http_code'] != 200) {
|
||
throw new HttpException("请求失败,response:" . $response, $curlInfo['http_code']);
|
||
}
|
||
return $response;
|
||
}
|
||
|
||
/**
|
||
* @var Option $option
|
||
*/
|
||
protected function post($url, $data, $header, $option)
|
||
{
|
||
$curl = curl_init();
|
||
|
||
curl_setopt_array($curl, array(
|
||
CURLOPT_URL => $url,
|
||
CURLOPT_RETURNTRANSFER => true,
|
||
CURLOPT_CONNECTTIMEOUT => $option->getConnectTimeout(),
|
||
CURLOPT_TIMEOUT => $option->getTimeout(),
|
||
CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
|
||
CURLOPT_CUSTOMREQUEST => 'POST',
|
||
CURLOPT_POSTFIELDS => http_build_query($data),
|
||
CURLOPT_HTTPHEADER => $header,
|
||
));
|
||
$response = curl_exec($curl);
|
||
|
||
if ($response == false) {
|
||
$errMsg = curl_error($curl);
|
||
curl_close($curl);
|
||
throw new HttpException("请求失败,response:" . $errMsg, 0);
|
||
}
|
||
|
||
$curlInfo = curl_getinfo($curl);
|
||
curl_close($curl);
|
||
|
||
if ($curlInfo['http_code'] != 200) {
|
||
throw new HttpException("请求失败,response:" . $response, $curlInfo['http_code']);
|
||
}
|
||
return $response;
|
||
}
|
||
|
||
protected function send($method, $path, $request, $responseDataClass, $option = null)
|
||
{
|
||
if (!is_null($option) && !$option instanceof Option) {
|
||
throw new ConfigException("参数 option 必须为 Yzh\\Request\\Option 实例", ExceptionCode::CONFIG_ERROR_WRONG_PARAM);
|
||
}
|
||
|
||
if (is_null($option)) {
|
||
$option = new Option(array('timeout' => $this->config->timeout));
|
||
}
|
||
|
||
// 获取接口请求参数
|
||
$requestData = $this->getRequestData($request);
|
||
$responseDecoder = property_exists($request, 'data_type') && $request->data_type == 'encryption' ? $this->des : null;
|
||
|
||
// 获取 url 的 path 部分, 将 path 部分拼接到传入的 path 上
|
||
$baseUrl = self::$env_service_host_map[$this->env][$this::$service_name];
|
||
if (empty($baseUrl)) {
|
||
throw new ConfigException('该环境不支持该请求,环境为:' . $this::$service_name, ExceptionCode::CONFIG_ERROR_UNSUPPORT_URL_IN_CURRENT_ENV);
|
||
}
|
||
|
||
$header = array(
|
||
'Content-Type: application/x-www-form-urlencoded',
|
||
'dealer-id: ' . $this->config->app_dealer_id,
|
||
'request-id: ' . $request->getRequestId(),
|
||
'User-Agent: ' . $this->generateUserAgent()
|
||
);
|
||
|
||
$url = $baseUrl . $path;
|
||
if ($method == "GET") {
|
||
$body = $this->get($url, $requestData, $header, $option);
|
||
} else {
|
||
$body = $this->post($url, $requestData, $header, $option);
|
||
}
|
||
|
||
/**
|
||
* @var BaseResponse $resp
|
||
*/
|
||
$resp = new $responseDataClass();
|
||
$respData = json_decode($body, true);
|
||
if (isset($respData['code'])) {
|
||
$resp->setCode($respData['code']);
|
||
}
|
||
|
||
if (isset($respData['message'])) {
|
||
$resp->setMessage($respData['message']);
|
||
}
|
||
|
||
$requestID = "";
|
||
if (isset($respData['request_id'])) {
|
||
$requestID = $respData['request_id'];
|
||
} elseif (isset($respData['requestID'])) {
|
||
$requestID = $respData['requestID'];
|
||
}
|
||
$resp->setRequestID($requestID);
|
||
|
||
if (!isset($respData['data']) || !class_exists($responseDataClass)) {
|
||
return $resp;
|
||
}
|
||
|
||
if (is_string($respData['data']) && !is_null($responseDecoder)) {
|
||
$data = json_decode($responseDecoder->decrypt($respData['data']), true);
|
||
} else {
|
||
$data = $respData['data'];
|
||
}
|
||
$resp->setData($data);
|
||
return $resp;
|
||
}
|
||
|
||
private function generateUserAgent()
|
||
{
|
||
return self::SDK_NAME . "/" . self::SDK_VERSION . "/" . PHP_VERSION;
|
||
}
|
||
|
||
private function getRequestData($request)
|
||
{
|
||
$encryptedBody = $this->des->encrypt(json_encode($request->getRequestData(), JSON_UNESCAPED_UNICODE));
|
||
$mess = MessString::rand(16);
|
||
$nowts = time();
|
||
if ($this->sign_type == Config::SIGN_TYPE_RSA) {
|
||
$sign = $this->rsa->sign(sprintf("data=%s&mess=%s×tamp=%d&key=%s", $encryptedBody, $mess, $nowts, $this->config->app_key));
|
||
} else {
|
||
$sign = $this->hmac->sign(sprintf("data=%s&mess=%s×tamp=%d&key=%s", $encryptedBody, $mess, $nowts, $this->config->app_key));
|
||
}
|
||
return array(
|
||
'data' => $encryptedBody,
|
||
'mess' => $mess,
|
||
'timestamp' => $nowts,
|
||
'sign' => $sign,
|
||
'sign_type' => $this->sign_type,
|
||
);
|
||
}
|
||
}
|