mirror of
https://gitee.com/yansongda/pay.git
synced 2024-11-29 18:58:38 +08:00
update
This commit is contained in:
yansongda
parent
5c6234e316
commit
fbe631651f
8
.gitattributes
vendored
Normal file
8
.gitattributes
vendored
Normal file
@ -0,0 +1,8 @@
|
||||
/tests export-ignore
|
||||
/.github export-ignore
|
||||
.gitattributes export-ignore
|
||||
.gitignore export-ignore
|
||||
phpunit.php export-ignore
|
||||
phpunit.xml export-ignore
|
||||
phpunit.xml.dist export-ignore
|
||||
.php_cs export-ignore
|
||||
9
src/Contract/ServiceInterface.php
Normal file
9
src/Contract/ServiceInterface.php
Normal file
@ -0,0 +1,9 @@
|
||||
<?php
|
||||
|
||||
namespace Yansongda\Pay\Contract;
|
||||
|
||||
use Pimple\ServiceProviderInterface;
|
||||
|
||||
interface ServiceInterface extends ServiceProviderInterface
|
||||
{
|
||||
}
|
||||
@ -1,87 +0,0 @@
|
||||
<?php
|
||||
|
||||
namespace Yansongda\Pay\Contracts;
|
||||
|
||||
use Symfony\Component\HttpFoundation\Response;
|
||||
use Yansongda\Supports\Collection;
|
||||
|
||||
interface GatewayApplicationInterface
|
||||
{
|
||||
/**
|
||||
* To pay.
|
||||
*
|
||||
* @author yansongda <me@yansonga.cn>
|
||||
*
|
||||
* @param string $gateway
|
||||
* @param array $params
|
||||
*
|
||||
* @return Collection|Response
|
||||
*/
|
||||
public function pay($gateway, $params);
|
||||
|
||||
/**
|
||||
* Query an order.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param string|array $order
|
||||
* @param string $type
|
||||
*
|
||||
* @return Collection
|
||||
*/
|
||||
public function find($order, string $type);
|
||||
|
||||
/**
|
||||
* Refund an order.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param array $order
|
||||
*
|
||||
* @return Collection
|
||||
*/
|
||||
public function refund(array $order);
|
||||
|
||||
/**
|
||||
* Cancel an order.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param string|array $order
|
||||
*
|
||||
* @return Collection
|
||||
*/
|
||||
public function cancel($order);
|
||||
|
||||
/**
|
||||
* Close an order.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param string|array $order
|
||||
*
|
||||
* @return Collection
|
||||
*/
|
||||
public function close($order);
|
||||
|
||||
/**
|
||||
* Verify a request.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param string|array|null $content
|
||||
* @param bool $refund
|
||||
*
|
||||
* @return Collection
|
||||
*/
|
||||
public function verify($content, bool $refund);
|
||||
|
||||
/**
|
||||
* Echo success to server.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @return Response
|
||||
*/
|
||||
public function success();
|
||||
}
|
||||
@ -1,21 +0,0 @@
|
||||
<?php
|
||||
|
||||
namespace Yansongda\Pay\Contracts;
|
||||
|
||||
use Symfony\Component\HttpFoundation\Response;
|
||||
use Yansongda\Supports\Collection;
|
||||
|
||||
interface GatewayInterface
|
||||
{
|
||||
/**
|
||||
* Pay an order.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param string $endpoint
|
||||
* @param array $payload
|
||||
*
|
||||
* @return Collection|Response
|
||||
*/
|
||||
public function pay($endpoint, array $payload);
|
||||
}
|
||||
106
src/Events.php
106
src/Events.php
@ -1,106 +0,0 @@
|
||||
<?php
|
||||
|
||||
namespace Yansongda\Pay;
|
||||
|
||||
use Exception;
|
||||
use Symfony\Component\EventDispatcher\EventDispatcher;
|
||||
use Symfony\Component\EventDispatcher\EventSubscriberInterface;
|
||||
use Symfony\Contracts\EventDispatcher\Event;
|
||||
|
||||
/**
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @method static Event dispatch(Event $event) Dispatches an event to all registered listeners
|
||||
* @method static array getListeners($eventName = null) Gets the listeners of a specific event or all listeners sorted by descending priority.
|
||||
* @method static int|void getListenerPriority($eventName, $listener) Gets the listener priority for a specific event.
|
||||
* @method static bool hasListeners($eventName = null) Checks whether an event has any registered listeners.
|
||||
* @method static void addListener($eventName, $listener, $priority = 0) Adds an event listener that listens on the specified events.
|
||||
* @method static removeListener($eventName, $listener) Removes an event listener from the specified events.
|
||||
* @method static void addSubscriber(EventSubscriberInterface $subscriber) Adds an event subscriber.
|
||||
* @method static void removeSubscriber(EventSubscriberInterface $subscriber)
|
||||
*/
|
||||
class Events
|
||||
{
|
||||
/**
|
||||
* dispatcher.
|
||||
*
|
||||
* @var EventDispatcher
|
||||
*/
|
||||
protected static $dispatcher;
|
||||
|
||||
/**
|
||||
* Forward call.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param string $method
|
||||
* @param array $args
|
||||
*
|
||||
* @throws Exception
|
||||
*
|
||||
* @return mixed
|
||||
*/
|
||||
public static function __callStatic($method, $args)
|
||||
{
|
||||
return call_user_func_array([self::getDispatcher(), $method], $args);
|
||||
}
|
||||
|
||||
/**
|
||||
* Forward call.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param string $method
|
||||
* @param array $args
|
||||
*
|
||||
* @throws Exception
|
||||
*
|
||||
* @return mixed
|
||||
*/
|
||||
public function __call($method, $args)
|
||||
{
|
||||
return call_user_func_array([self::getDispatcher(), $method], $args);
|
||||
}
|
||||
|
||||
/**
|
||||
* setDispatcher.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param EventDispatcher $dispatcher
|
||||
*
|
||||
* @return void
|
||||
*/
|
||||
public static function setDispatcher(EventDispatcher $dispatcher)
|
||||
{
|
||||
self::$dispatcher = $dispatcher;
|
||||
}
|
||||
|
||||
/**
|
||||
* getDispatcher.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @return EventDispatcher
|
||||
*/
|
||||
public static function getDispatcher(): EventDispatcher
|
||||
{
|
||||
if (self::$dispatcher) {
|
||||
return self::$dispatcher;
|
||||
}
|
||||
|
||||
return self::$dispatcher = self::createDispatcher();
|
||||
}
|
||||
|
||||
/**
|
||||
* createDispatcher.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @return EventDispatcher
|
||||
*/
|
||||
public static function createDispatcher(): EventDispatcher
|
||||
{
|
||||
return new EventDispatcher();
|
||||
}
|
||||
}
|
||||
@ -1,36 +0,0 @@
|
||||
<?php
|
||||
|
||||
namespace Yansongda\Pay\Events;
|
||||
|
||||
class ApiRequested extends Event
|
||||
{
|
||||
/**
|
||||
* Endpoint.
|
||||
*
|
||||
* @var string
|
||||
*/
|
||||
public $endpoint;
|
||||
|
||||
/**
|
||||
* Result.
|
||||
*
|
||||
* @var array
|
||||
*/
|
||||
public $result;
|
||||
|
||||
/**
|
||||
* Bootstrap.
|
||||
*
|
||||
* @param string $driver
|
||||
* @param string $gateway
|
||||
* @param string $endpoint
|
||||
* @param array $result
|
||||
*/
|
||||
public function __construct(string $driver, string $gateway, string $endpoint, array $result)
|
||||
{
|
||||
$this->endpoint = $endpoint;
|
||||
$this->result = $result;
|
||||
|
||||
parent::__construct($driver, $gateway);
|
||||
}
|
||||
}
|
||||
@ -1,36 +0,0 @@
|
||||
<?php
|
||||
|
||||
namespace Yansongda\Pay\Events;
|
||||
|
||||
class ApiRequesting extends Event
|
||||
{
|
||||
/**
|
||||
* Endpoint.
|
||||
*
|
||||
* @var string
|
||||
*/
|
||||
public $endpoint;
|
||||
|
||||
/**
|
||||
* Payload.
|
||||
*
|
||||
* @var array
|
||||
*/
|
||||
public $payload;
|
||||
|
||||
/**
|
||||
* Bootstrap.
|
||||
*
|
||||
* @param string $driver
|
||||
* @param string $gateway
|
||||
* @param string $endpoint
|
||||
* @param array $payload
|
||||
*/
|
||||
public function __construct(string $driver, string $gateway, string $endpoint, array $payload)
|
||||
{
|
||||
$this->endpoint = $endpoint;
|
||||
$this->payload = $payload;
|
||||
|
||||
parent::__construct($driver, $gateway);
|
||||
}
|
||||
}
|
||||
@ -1,43 +0,0 @@
|
||||
<?php
|
||||
|
||||
namespace Yansongda\Pay\Events;
|
||||
|
||||
use Symfony\Contracts\EventDispatcher\Event as SymfonyEvent;
|
||||
|
||||
class Event extends SymfonyEvent
|
||||
{
|
||||
/**
|
||||
* Driver.
|
||||
*
|
||||
* @var string
|
||||
*/
|
||||
public $driver;
|
||||
|
||||
/**
|
||||
* Method.
|
||||
*
|
||||
* @var string
|
||||
*/
|
||||
public $gateway;
|
||||
|
||||
/**
|
||||
* Extra attributes.
|
||||
*
|
||||
* @var mixed
|
||||
*/
|
||||
public $attributes;
|
||||
|
||||
/**
|
||||
* Bootstrap.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param string $driver
|
||||
* @param string $gateway
|
||||
*/
|
||||
public function __construct(string $driver, string $gateway)
|
||||
{
|
||||
$this->driver = $driver;
|
||||
$this->gateway = $gateway;
|
||||
}
|
||||
}
|
||||
@ -1,38 +0,0 @@
|
||||
<?php
|
||||
|
||||
namespace Yansongda\Pay\Events;
|
||||
|
||||
class MethodCalled extends Event
|
||||
{
|
||||
/**
|
||||
* endpoint.
|
||||
*
|
||||
* @var string
|
||||
*/
|
||||
public $endpoint;
|
||||
|
||||
/**
|
||||
* payload.
|
||||
*
|
||||
* @var array
|
||||
*/
|
||||
public $payload;
|
||||
|
||||
/**
|
||||
* Bootstrap.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param string $driver
|
||||
* @param string $gateway
|
||||
* @param string $endpoint
|
||||
* @param array $payload
|
||||
*/
|
||||
public function __construct(string $driver, string $gateway, string $endpoint, array $payload = [])
|
||||
{
|
||||
$this->endpoint = $endpoint;
|
||||
$this->payload = $payload;
|
||||
|
||||
parent::__construct($driver, $gateway);
|
||||
}
|
||||
}
|
||||
@ -1,36 +0,0 @@
|
||||
<?php
|
||||
|
||||
namespace Yansongda\Pay\Events;
|
||||
|
||||
class PayStarted extends Event
|
||||
{
|
||||
/**
|
||||
* Endpoint.
|
||||
*
|
||||
* @var string
|
||||
*/
|
||||
public $endpoint;
|
||||
|
||||
/**
|
||||
* Payload.
|
||||
*
|
||||
* @var array
|
||||
*/
|
||||
public $payload;
|
||||
|
||||
/**
|
||||
* Bootstrap.
|
||||
*
|
||||
* @param string $driver
|
||||
* @param string $gateway
|
||||
* @param string $endpoint
|
||||
* @param array $payload
|
||||
*/
|
||||
public function __construct(string $driver, string $gateway, string $endpoint, array $payload)
|
||||
{
|
||||
$this->endpoint = $endpoint;
|
||||
$this->payload = $payload;
|
||||
|
||||
parent::__construct($driver, $gateway);
|
||||
}
|
||||
}
|
||||
@ -1,27 +0,0 @@
|
||||
<?php
|
||||
|
||||
namespace Yansongda\Pay\Events;
|
||||
|
||||
class PayStarting extends Event
|
||||
{
|
||||
/**
|
||||
* Params.
|
||||
*
|
||||
* @var array
|
||||
*/
|
||||
public $params;
|
||||
|
||||
/**
|
||||
* Bootstrap.
|
||||
*
|
||||
* @param string $driver
|
||||
* @param string $gateway
|
||||
* @param array $params
|
||||
*/
|
||||
public function __construct(string $driver, string $gateway, array $params)
|
||||
{
|
||||
$this->params = $params;
|
||||
|
||||
parent::__construct($driver, $gateway);
|
||||
}
|
||||
}
|
||||
@ -1,29 +0,0 @@
|
||||
<?php
|
||||
|
||||
namespace Yansongda\Pay\Events;
|
||||
|
||||
class RequestReceived extends Event
|
||||
{
|
||||
/**
|
||||
* Received data.
|
||||
*
|
||||
* @var array
|
||||
*/
|
||||
public $data;
|
||||
|
||||
/**
|
||||
* Bootstrap.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param string $driver
|
||||
* @param string $gateway
|
||||
* @param array $data
|
||||
*/
|
||||
public function __construct(string $driver, string $gateway, array $data)
|
||||
{
|
||||
$this->data = $data;
|
||||
|
||||
parent::__construct($driver, $gateway);
|
||||
}
|
||||
}
|
||||
@ -1,29 +0,0 @@
|
||||
<?php
|
||||
|
||||
namespace Yansongda\Pay\Events;
|
||||
|
||||
class SignFailed extends Event
|
||||
{
|
||||
/**
|
||||
* Received data.
|
||||
*
|
||||
* @var array
|
||||
*/
|
||||
public $data;
|
||||
|
||||
/**
|
||||
* Bootstrap.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param string $driver
|
||||
* @param string $gateway
|
||||
* @param array $data
|
||||
*/
|
||||
public function __construct(string $driver, string $gateway, array $data)
|
||||
{
|
||||
$this->data = $data;
|
||||
|
||||
parent::__construct($driver, $gateway);
|
||||
}
|
||||
}
|
||||
@ -1,19 +0,0 @@
|
||||
<?php
|
||||
|
||||
namespace Yansongda\Pay\Exceptions;
|
||||
|
||||
class BusinessException extends GatewayException
|
||||
{
|
||||
/**
|
||||
* Bootstrap.
|
||||
*
|
||||
* @author yansongda <me@yansonga.cn>
|
||||
*
|
||||
* @param string $message
|
||||
* @param array|string $raw
|
||||
*/
|
||||
public function __construct($message, $raw = [])
|
||||
{
|
||||
parent::__construct('ERROR_BUSINESS: '.$message, $raw, self::ERROR_BUSINESS);
|
||||
}
|
||||
}
|
||||
@ -1,44 +0,0 @@
|
||||
<?php
|
||||
|
||||
namespace Yansongda\Pay\Exceptions;
|
||||
|
||||
class Exception extends \Exception
|
||||
{
|
||||
const UNKNOWN_ERROR = 9999;
|
||||
|
||||
const INVALID_GATEWAY = 1;
|
||||
|
||||
const INVALID_CONFIG = 2;
|
||||
|
||||
const INVALID_ARGUMENT = 3;
|
||||
|
||||
const ERROR_GATEWAY = 4;
|
||||
|
||||
const INVALID_SIGN = 5;
|
||||
|
||||
const ERROR_BUSINESS = 6;
|
||||
|
||||
/**
|
||||
* Raw error info.
|
||||
*
|
||||
* @var array
|
||||
*/
|
||||
public $raw;
|
||||
|
||||
/**
|
||||
* Bootstrap.
|
||||
*
|
||||
* @author yansongda <me@yansonga.cn>
|
||||
*
|
||||
* @param string $message
|
||||
* @param array|string $raw
|
||||
* @param int|string $code
|
||||
*/
|
||||
public function __construct($message = '', $raw = [], $code = self::UNKNOWN_ERROR)
|
||||
{
|
||||
$message = $message === '' ? 'Unknown Error' : $message;
|
||||
$this->raw = is_array($raw) ? $raw : [$raw];
|
||||
|
||||
parent::__construct($message, intval($code));
|
||||
}
|
||||
}
|
||||
@ -1,20 +0,0 @@
|
||||
<?php
|
||||
|
||||
namespace Yansongda\Pay\Exceptions;
|
||||
|
||||
class GatewayException extends Exception
|
||||
{
|
||||
/**
|
||||
* Bootstrap.
|
||||
*
|
||||
* @author yansongda <me@yansonga.cn>
|
||||
*
|
||||
* @param string $message
|
||||
* @param array|string $raw
|
||||
* @param int $code
|
||||
*/
|
||||
public function __construct($message, $raw = [], $code = self::ERROR_GATEWAY)
|
||||
{
|
||||
parent::__construct('ERROR_GATEWAY: '.$message, $raw, $code);
|
||||
}
|
||||
}
|
||||
@ -1,19 +0,0 @@
|
||||
<?php
|
||||
|
||||
namespace Yansongda\Pay\Exceptions;
|
||||
|
||||
class InvalidArgumentException extends Exception
|
||||
{
|
||||
/**
|
||||
* Bootstrap.
|
||||
*
|
||||
* @author yansongda <me@yansonga.cn>
|
||||
*
|
||||
* @param string $message
|
||||
* @param array|string $raw
|
||||
*/
|
||||
public function __construct($message, $raw = [])
|
||||
{
|
||||
parent::__construct('INVALID_ARGUMENT: '.$message, $raw, self::INVALID_ARGUMENT);
|
||||
}
|
||||
}
|
||||
@ -1,19 +0,0 @@
|
||||
<?php
|
||||
|
||||
namespace Yansongda\Pay\Exceptions;
|
||||
|
||||
class InvalidConfigException extends Exception
|
||||
{
|
||||
/**
|
||||
* Bootstrap.
|
||||
*
|
||||
* @author yansongda <me@yansonga.cn>
|
||||
*
|
||||
* @param string $message
|
||||
* @param array|string $raw
|
||||
*/
|
||||
public function __construct($message, $raw = [])
|
||||
{
|
||||
parent::__construct('INVALID_CONFIG: '.$message, $raw, self::INVALID_CONFIG);
|
||||
}
|
||||
}
|
||||
@ -1,19 +0,0 @@
|
||||
<?php
|
||||
|
||||
namespace Yansongda\Pay\Exceptions;
|
||||
|
||||
class InvalidGatewayException extends Exception
|
||||
{
|
||||
/**
|
||||
* Bootstrap.
|
||||
*
|
||||
* @author yansongda <me@yansonga.cn>
|
||||
*
|
||||
* @param string $message
|
||||
* @param array|string $raw
|
||||
*/
|
||||
public function __construct($message, $raw = [])
|
||||
{
|
||||
parent::__construct('INVALID_GATEWAY: '.$message, $raw, self::INVALID_GATEWAY);
|
||||
}
|
||||
}
|
||||
@ -1,19 +0,0 @@
|
||||
<?php
|
||||
|
||||
namespace Yansongda\Pay\Exceptions;
|
||||
|
||||
class InvalidSignException extends Exception
|
||||
{
|
||||
/**
|
||||
* Bootstrap.
|
||||
*
|
||||
* @author yansongda <me@yansonga.cn>
|
||||
*
|
||||
* @param string $message
|
||||
* @param array|string $raw
|
||||
*/
|
||||
public function __construct($message, $raw = [])
|
||||
{
|
||||
parent::__construct('INVALID_SIGN: '.$message, $raw, self::INVALID_SIGN);
|
||||
}
|
||||
}
|
||||
@ -1,443 +0,0 @@
|
||||
<?php
|
||||
|
||||
namespace Yansongda\Pay\Gateways;
|
||||
|
||||
use Symfony\Component\HttpFoundation\Request;
|
||||
use Symfony\Component\HttpFoundation\Response;
|
||||
use Yansongda\Pay\Contracts\GatewayApplicationInterface;
|
||||
use Yansongda\Pay\Contracts\GatewayInterface;
|
||||
use Yansongda\Pay\Events;
|
||||
use Yansongda\Pay\Exceptions\GatewayException;
|
||||
use Yansongda\Pay\Exceptions\InvalidArgumentException;
|
||||
use Yansongda\Pay\Exceptions\InvalidConfigException;
|
||||
use Yansongda\Pay\Exceptions\InvalidGatewayException;
|
||||
use Yansongda\Pay\Exceptions\InvalidSignException;
|
||||
use Yansongda\Pay\Gateways\Alipay\Support;
|
||||
use Yansongda\Supports\Collection;
|
||||
use Yansongda\Supports\Config;
|
||||
use Yansongda\Supports\Str;
|
||||
|
||||
/**
|
||||
* @method Response app(array $config) APP 支付
|
||||
* @method Collection pos(array $config) 刷卡支付
|
||||
* @method Collection scan(array $config) 扫码支付
|
||||
* @method Collection transfer(array $config) 帐户转账
|
||||
* @method Response wap(array $config) 手机网站支付
|
||||
* @method Response web(array $config) 电脑支付
|
||||
* @method Collection mini(array $config) 小程序支付
|
||||
*/
|
||||
class Alipay implements GatewayApplicationInterface
|
||||
{
|
||||
/**
|
||||
* Const mode_normal.
|
||||
*/
|
||||
const MODE_NORMAL = 'normal';
|
||||
|
||||
/**
|
||||
* Const mode_dev.
|
||||
*/
|
||||
const MODE_DEV = 'dev';
|
||||
|
||||
/**
|
||||
* Const url.
|
||||
*/
|
||||
const URL = [
|
||||
self::MODE_NORMAL => 'https://openapi.alipay.com/gateway.do?charset=utf-8',
|
||||
self::MODE_DEV => 'https://openapi.alipaydev.com/gateway.do?charset=utf-8',
|
||||
];
|
||||
|
||||
/**
|
||||
* Alipay payload.
|
||||
*
|
||||
* @var array
|
||||
*/
|
||||
protected $payload;
|
||||
|
||||
/**
|
||||
* Alipay gateway.
|
||||
*
|
||||
* @var string
|
||||
*/
|
||||
protected $gateway;
|
||||
|
||||
/**
|
||||
* extends.
|
||||
*
|
||||
* @var array
|
||||
*/
|
||||
protected $extends;
|
||||
|
||||
/**
|
||||
* Bootstrap.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param Config $config
|
||||
*/
|
||||
public function __construct(Config $config)
|
||||
{
|
||||
$this->gateway = Support::create($config)->getBaseUri();
|
||||
$this->payload = [
|
||||
'app_id' => $config->get('app_id'),
|
||||
'method' => '',
|
||||
'format' => 'JSON',
|
||||
'charset' => 'utf-8',
|
||||
'sign_type' => 'RSA2',
|
||||
'version' => '1.0',
|
||||
'return_url' => $config->get('return_url'),
|
||||
'notify_url' => $config->get('notify_url'),
|
||||
'timestamp' => date('Y-m-d H:i:s'),
|
||||
'sign' => '',
|
||||
'biz_content' => '',
|
||||
'app_auth_token' => $config->get('app_auth_token'),
|
||||
];
|
||||
}
|
||||
|
||||
/**
|
||||
* Magic pay.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param string $method
|
||||
* @param array $params
|
||||
*
|
||||
* @throws GatewayException
|
||||
* @throws InvalidArgumentException
|
||||
* @throws InvalidConfigException
|
||||
* @throws InvalidGatewayException
|
||||
* @throws InvalidSignException
|
||||
*
|
||||
* @return Response|Collection
|
||||
*/
|
||||
public function __call($method, $params)
|
||||
{
|
||||
if (isset($this->extends[$method])) {
|
||||
return $this->makeExtend($method, ...$params);
|
||||
}
|
||||
|
||||
return $this->pay($method, ...$params);
|
||||
}
|
||||
|
||||
/**
|
||||
* Pay an order.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param string $gateway
|
||||
* @param array $params
|
||||
*
|
||||
* @throws InvalidGatewayException
|
||||
*
|
||||
* @return Response|Collection
|
||||
*/
|
||||
public function pay($gateway, $params = [])
|
||||
{
|
||||
Events::dispatch(new Events\PayStarting('Alipay', $gateway, $params));
|
||||
|
||||
$this->payload['return_url'] = $params['return_url'] ?? $this->payload['return_url'];
|
||||
$this->payload['notify_url'] = $params['notify_url'] ?? $this->payload['notify_url'];
|
||||
|
||||
unset($params['return_url'], $params['notify_url']);
|
||||
|
||||
$this->payload['biz_content'] = json_encode($params);
|
||||
|
||||
$gateway = get_class($this).'\\'.Str::studly($gateway).'Gateway';
|
||||
|
||||
if (class_exists($gateway)) {
|
||||
return $this->makePay($gateway);
|
||||
}
|
||||
|
||||
throw new InvalidGatewayException("Pay Gateway [{$gateway}] not exists");
|
||||
}
|
||||
|
||||
/**
|
||||
* Verify sign.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param null|array $data
|
||||
* @param bool $refund
|
||||
*
|
||||
* @throws InvalidSignException
|
||||
* @throws InvalidConfigException
|
||||
*
|
||||
* @return Collection
|
||||
*/
|
||||
public function verify($data = null, bool $refund = false): Collection
|
||||
{
|
||||
if (is_null($data)) {
|
||||
$request = Request::createFromGlobals();
|
||||
|
||||
$data = $request->request->count() > 0 ? $request->request->all() : $request->query->all();
|
||||
}
|
||||
|
||||
if (isset($data['fund_bill_list'])) {
|
||||
$data['fund_bill_list'] = htmlspecialchars_decode($data['fund_bill_list']);
|
||||
}
|
||||
|
||||
Events::dispatch(new Events\RequestReceived('Alipay', '', $data));
|
||||
|
||||
if (Support::verifySign($data)) {
|
||||
return new Collection($data);
|
||||
}
|
||||
|
||||
Events::dispatch(new Events\SignFailed('Alipay', '', $data));
|
||||
|
||||
throw new InvalidSignException('Alipay Sign Verify FAILED', $data);
|
||||
}
|
||||
|
||||
/**
|
||||
* Query an order.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param string|array $order
|
||||
* @param string $type
|
||||
*
|
||||
* @throws GatewayException
|
||||
* @throws InvalidConfigException
|
||||
* @throws InvalidSignException
|
||||
*
|
||||
* @return Collection
|
||||
*/
|
||||
public function find($order, string $type = 'wap'): Collection
|
||||
{
|
||||
$gateway = get_class($this).'\\'.Str::studly($type).'Gateway';
|
||||
|
||||
if (!class_exists($gateway) || !is_callable([new $gateway(), 'find'])) {
|
||||
throw new GatewayException("{$gateway} Done Not Exist Or Done Not Has FIND Method");
|
||||
}
|
||||
|
||||
$config = call_user_func([new $gateway(), 'find'], $order);
|
||||
|
||||
$this->payload['method'] = $config['method'];
|
||||
$this->payload['biz_content'] = $config['biz_content'];
|
||||
$this->payload['sign'] = Support::generateSign($this->payload);
|
||||
|
||||
Events::dispatch(new Events\MethodCalled('Alipay', 'Find', $this->gateway, $this->payload));
|
||||
|
||||
return Support::requestApi($this->payload);
|
||||
}
|
||||
|
||||
/**
|
||||
* Refund an order.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param array $order
|
||||
*
|
||||
* @throws GatewayException
|
||||
* @throws InvalidConfigException
|
||||
* @throws InvalidSignException
|
||||
*
|
||||
* @return Collection
|
||||
*/
|
||||
public function refund(array $order): Collection
|
||||
{
|
||||
$this->payload['method'] = 'alipay.trade.refund';
|
||||
$this->payload['biz_content'] = json_encode($order);
|
||||
$this->payload['sign'] = Support::generateSign($this->payload);
|
||||
|
||||
Events::dispatch(new Events\MethodCalled('Alipay', 'Refund', $this->gateway, $this->payload));
|
||||
|
||||
return Support::requestApi($this->payload);
|
||||
}
|
||||
|
||||
/**
|
||||
* Cancel an order.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param array|string $order
|
||||
*
|
||||
* @throws GatewayException
|
||||
* @throws InvalidConfigException
|
||||
* @throws InvalidSignException
|
||||
*
|
||||
* @return Collection
|
||||
*/
|
||||
public function cancel($order): Collection
|
||||
{
|
||||
$this->payload['method'] = 'alipay.trade.cancel';
|
||||
$this->payload['biz_content'] = json_encode(is_array($order) ? $order : ['out_trade_no' => $order]);
|
||||
$this->payload['sign'] = Support::generateSign($this->payload);
|
||||
|
||||
Events::dispatch(new Events\MethodCalled('Alipay', 'Cancel', $this->gateway, $this->payload));
|
||||
|
||||
return Support::requestApi($this->payload);
|
||||
}
|
||||
|
||||
/**
|
||||
* Close an order.
|
||||
*
|
||||
* @param string|array $order
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @throws GatewayException
|
||||
* @throws InvalidConfigException
|
||||
* @throws InvalidSignException
|
||||
*
|
||||
* @return Collection
|
||||
*/
|
||||
public function close($order): Collection
|
||||
{
|
||||
$this->payload['method'] = 'alipay.trade.close';
|
||||
$this->payload['biz_content'] = json_encode(is_array($order) ? $order : ['out_trade_no' => $order]);
|
||||
$this->payload['sign'] = Support::generateSign($this->payload);
|
||||
|
||||
Events::dispatch(new Events\MethodCalled('Alipay', 'Close', $this->gateway, $this->payload));
|
||||
|
||||
return Support::requestApi($this->payload);
|
||||
}
|
||||
|
||||
/**
|
||||
* Download bill.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param string|array $bill
|
||||
*
|
||||
* @throws GatewayException
|
||||
* @throws InvalidConfigException
|
||||
* @throws InvalidSignException
|
||||
*
|
||||
* @return string
|
||||
*/
|
||||
public function download($bill): string
|
||||
{
|
||||
$this->payload['method'] = 'alipay.data.dataservice.bill.downloadurl.query';
|
||||
$this->payload['biz_content'] = json_encode(is_array($bill) ? $bill : ['bill_type' => 'trade', 'bill_date' => $bill]);
|
||||
$this->payload['sign'] = Support::generateSign($this->payload);
|
||||
|
||||
Events::dispatch(new Events\MethodCalled('Alipay', 'Download', $this->gateway, $this->payload));
|
||||
|
||||
$result = Support::requestApi($this->payload);
|
||||
|
||||
return ($result instanceof Collection) ? $result->get('bill_download_url') : '';
|
||||
}
|
||||
|
||||
/**
|
||||
* Reply success to alipay.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @return Response
|
||||
*/
|
||||
public function success(): Response
|
||||
{
|
||||
Events::dispatch(new Events\MethodCalled('Alipay', 'Success', $this->gateway));
|
||||
|
||||
return Response::create('success');
|
||||
}
|
||||
|
||||
/**
|
||||
* extend.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param string $method
|
||||
* @param callable $function
|
||||
* @param bool $now
|
||||
*
|
||||
* @throws GatewayException
|
||||
* @throws InvalidConfigException
|
||||
* @throws InvalidSignException
|
||||
* @throws InvalidArgumentException
|
||||
*
|
||||
* @return Collection|null
|
||||
*/
|
||||
public function extend(string $method, callable $function, bool $now = true): ?Collection
|
||||
{
|
||||
if (!$now && !method_exists($this, $method)) {
|
||||
$this->extends[$method] = $function;
|
||||
|
||||
return null;
|
||||
}
|
||||
|
||||
$customize = $function($this->payload);
|
||||
|
||||
if (!is_array($customize) && !($customize instanceof Collection)) {
|
||||
throw new InvalidArgumentException('Return Type Must Be Array Or Collection');
|
||||
}
|
||||
|
||||
Events::dispatch(new Events\MethodCalled('Alipay', 'extend', $this->gateway, $customize));
|
||||
|
||||
if (is_array($customize)) {
|
||||
$this->payload = $customize;
|
||||
$this->payload['sign'] = Support::generateSign($this->payload);
|
||||
|
||||
return Support::requestApi($this->payload);
|
||||
}
|
||||
|
||||
return $customize;
|
||||
}
|
||||
|
||||
/**
|
||||
* Make pay gateway.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param string $gateway
|
||||
*
|
||||
* @throws InvalidGatewayException
|
||||
*
|
||||
* @return Response|Collection
|
||||
*/
|
||||
protected function makePay(string $gateway)
|
||||
{
|
||||
$app = new $gateway();
|
||||
|
||||
if ($app instanceof GatewayInterface) {
|
||||
return $app->pay($this->gateway, array_filter($this->payload, function ($value) {
|
||||
return $value !== '' && !is_null($value);
|
||||
}));
|
||||
}
|
||||
|
||||
throw new InvalidGatewayException("Pay Gateway [{$gateway}] Must Be An Instance Of GatewayInterface");
|
||||
}
|
||||
|
||||
/**
|
||||
* makeExtend.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param string $method
|
||||
* @param array $params
|
||||
*
|
||||
* @throws GatewayException
|
||||
* @throws InvalidArgumentException
|
||||
* @throws InvalidConfigException
|
||||
* @throws InvalidSignException
|
||||
*
|
||||
* @return Collection
|
||||
*/
|
||||
protected function makeExtend(string $method, array ...$params): Collection
|
||||
{
|
||||
$params = count($params) >= 1 ? $params[0] : $params;
|
||||
|
||||
$function = $this->extends[$method];
|
||||
|
||||
$customize = $function($this->payload, $params);
|
||||
|
||||
if (!is_array($customize) && !($customize instanceof Collection)) {
|
||||
throw new InvalidArgumentException('Return Type Must Be Array Or Collection');
|
||||
}
|
||||
|
||||
Events::dispatch(new Events\MethodCalled(
|
||||
'Alipay',
|
||||
'extend - '.$method,
|
||||
$this->gateway,
|
||||
is_array($customize) ? $customize : $customize->toArray()
|
||||
));
|
||||
|
||||
if (is_array($customize)) {
|
||||
$this->payload = $customize;
|
||||
$this->payload['sign'] = Support::generateSign($this->payload);
|
||||
|
||||
return Support::requestApi($this->payload);
|
||||
}
|
||||
|
||||
return $customize;
|
||||
}
|
||||
}
|
||||
@ -1,37 +0,0 @@
|
||||
<?php
|
||||
|
||||
namespace Yansongda\Pay\Gateways\Alipay;
|
||||
|
||||
use Symfony\Component\HttpFoundation\Response;
|
||||
use Yansongda\Pay\Contracts\GatewayInterface;
|
||||
use Yansongda\Pay\Events;
|
||||
use Yansongda\Pay\Exceptions\InvalidConfigException;
|
||||
|
||||
class AppGateway implements GatewayInterface
|
||||
{
|
||||
/**
|
||||
* Pay an order.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param string $endpoint
|
||||
* @param array $payload
|
||||
*
|
||||
* @throws InvalidConfigException
|
||||
*
|
||||
* @return Response
|
||||
*/
|
||||
public function pay($endpoint, array $payload): Response
|
||||
{
|
||||
$payload['method'] = 'alipay.trade.app.pay';
|
||||
$payload['biz_content'] = json_encode(array_merge(
|
||||
json_decode($payload['biz_content'], true),
|
||||
['product_code' => 'QUICK_MSECURITY_PAY']
|
||||
));
|
||||
$payload['sign'] = Support::generateSign($payload);
|
||||
|
||||
Events::dispatch(new Events\PayStarted('Alipay', 'App', $endpoint, $payload));
|
||||
|
||||
return Response::create(http_build_query($payload));
|
||||
}
|
||||
}
|
||||
@ -1,45 +0,0 @@
|
||||
<?php
|
||||
|
||||
namespace Yansongda\Pay\Gateways\Alipay;
|
||||
|
||||
use Yansongda\Pay\Contracts\GatewayInterface;
|
||||
use Yansongda\Pay\Events;
|
||||
use Yansongda\Pay\Exceptions\GatewayException;
|
||||
use Yansongda\Pay\Exceptions\InvalidArgumentException;
|
||||
use Yansongda\Pay\Exceptions\InvalidConfigException;
|
||||
use Yansongda\Pay\Exceptions\InvalidSignException;
|
||||
use Yansongda\Supports\Collection;
|
||||
|
||||
class MiniGateway implements GatewayInterface
|
||||
{
|
||||
/**
|
||||
* Pay an order.
|
||||
*
|
||||
* @author xiaozan <i@xiaozan.me>
|
||||
*
|
||||
* @param string $endpoint
|
||||
* @param array $payload
|
||||
*
|
||||
* @throws GatewayException
|
||||
* @throws InvalidArgumentException
|
||||
* @throws InvalidConfigException
|
||||
* @throws InvalidSignException
|
||||
*
|
||||
* @link https://docs.alipay.com/mini/introduce/pay
|
||||
*
|
||||
* @return Collection
|
||||
*/
|
||||
public function pay($endpoint, array $payload): Collection
|
||||
{
|
||||
if (empty(json_decode($payload['biz_content'], true)['buyer_id'])) {
|
||||
throw new InvalidArgumentException('buyer_id required');
|
||||
}
|
||||
|
||||
$payload['method'] = 'alipay.trade.create';
|
||||
$payload['sign'] = Support::generateSign($payload);
|
||||
|
||||
Events::dispatch(new Events\PayStarted('Alipay', 'Mini', $endpoint, $payload));
|
||||
|
||||
return Support::requestApi($payload);
|
||||
}
|
||||
}
|
||||
@ -1,44 +0,0 @@
|
||||
<?php
|
||||
|
||||
namespace Yansongda\Pay\Gateways\Alipay;
|
||||
|
||||
use Yansongda\Pay\Contracts\GatewayInterface;
|
||||
use Yansongda\Pay\Events;
|
||||
use Yansongda\Pay\Exceptions\GatewayException;
|
||||
use Yansongda\Pay\Exceptions\InvalidConfigException;
|
||||
use Yansongda\Pay\Exceptions\InvalidSignException;
|
||||
use Yansongda\Supports\Collection;
|
||||
|
||||
class PosGateway implements GatewayInterface
|
||||
{
|
||||
/**
|
||||
* Pay an order.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param string $endpoint
|
||||
* @param array $payload
|
||||
*
|
||||
* @throws GatewayException
|
||||
* @throws InvalidConfigException
|
||||
* @throws InvalidSignException
|
||||
*
|
||||
* @return Collection
|
||||
*/
|
||||
public function pay($endpoint, array $payload): Collection
|
||||
{
|
||||
$payload['method'] = 'alipay.trade.pay';
|
||||
$payload['biz_content'] = json_encode(array_merge(
|
||||
json_decode($payload['biz_content'], true),
|
||||
[
|
||||
'product_code' => 'FACE_TO_FACE_PAYMENT',
|
||||
'scene' => 'bar_code',
|
||||
]
|
||||
));
|
||||
$payload['sign'] = Support::generateSign($payload);
|
||||
|
||||
Events::dispatch(new Events\PayStarted('Alipay', 'Pos', $endpoint, $payload));
|
||||
|
||||
return Support::requestApi($payload);
|
||||
}
|
||||
}
|
||||
@ -1,23 +0,0 @@
|
||||
<?php
|
||||
|
||||
namespace Yansongda\Pay\Gateways\Alipay;
|
||||
|
||||
class RefundGateway
|
||||
{
|
||||
/**
|
||||
* Find.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param $order
|
||||
*
|
||||
* @return array
|
||||
*/
|
||||
public function find($order): array
|
||||
{
|
||||
return [
|
||||
'method' => 'alipay.trade.fastpay.refund.query',
|
||||
'biz_content' => json_encode(is_array($order) ? $order : ['out_trade_no' => $order]),
|
||||
];
|
||||
}
|
||||
}
|
||||
@ -1,41 +0,0 @@
|
||||
<?php
|
||||
|
||||
namespace Yansongda\Pay\Gateways\Alipay;
|
||||
|
||||
use Yansongda\Pay\Contracts\GatewayInterface;
|
||||
use Yansongda\Pay\Events;
|
||||
use Yansongda\Pay\Exceptions\GatewayException;
|
||||
use Yansongda\Pay\Exceptions\InvalidConfigException;
|
||||
use Yansongda\Pay\Exceptions\InvalidSignException;
|
||||
use Yansongda\Supports\Collection;
|
||||
|
||||
class ScanGateway implements GatewayInterface
|
||||
{
|
||||
/**
|
||||
* Pay an order.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param string $endpoint
|
||||
* @param array $payload
|
||||
*
|
||||
* @throws GatewayException
|
||||
* @throws InvalidConfigException
|
||||
* @throws InvalidSignException
|
||||
*
|
||||
* @return Collection
|
||||
*/
|
||||
public function pay($endpoint, array $payload): Collection
|
||||
{
|
||||
$payload['method'] = 'alipay.trade.precreate';
|
||||
$payload['biz_content'] = json_encode(array_merge(
|
||||
json_decode($payload['biz_content'], true),
|
||||
['product_code' => '']
|
||||
));
|
||||
$payload['sign'] = Support::generateSign($payload);
|
||||
|
||||
Events::dispatch(new Events\PayStarted('Alipay', 'Scan', $endpoint, $payload));
|
||||
|
||||
return Support::requestApi($payload);
|
||||
}
|
||||
}
|
||||
@ -1,354 +0,0 @@
|
||||
<?php
|
||||
|
||||
namespace Yansongda\Pay\Gateways\Alipay;
|
||||
|
||||
use Yansongda\Pay\Events;
|
||||
use Yansongda\Pay\Exceptions\GatewayException;
|
||||
use Yansongda\Pay\Exceptions\InvalidConfigException;
|
||||
use Yansongda\Pay\Exceptions\InvalidSignException;
|
||||
use Yansongda\Pay\Gateways\Alipay;
|
||||
use Yansongda\Pay\Log;
|
||||
use Yansongda\Supports\Arr;
|
||||
use Yansongda\Supports\Collection;
|
||||
use Yansongda\Supports\Config;
|
||||
use Yansongda\Supports\Str;
|
||||
use Yansongda\Supports\Traits\HasHttpRequest;
|
||||
|
||||
/**
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @property string app_id alipay app_id
|
||||
* @property string ali_public_key
|
||||
* @property string private_key
|
||||
* @property array http http options
|
||||
* @property string mode current mode
|
||||
* @property array log log options
|
||||
*/
|
||||
class Support
|
||||
{
|
||||
use HasHttpRequest;
|
||||
|
||||
/**
|
||||
* Alipay gateway.
|
||||
*
|
||||
* @var string
|
||||
*/
|
||||
protected $baseUri;
|
||||
|
||||
/**
|
||||
* Config.
|
||||
*
|
||||
* @var Config
|
||||
*/
|
||||
protected $config;
|
||||
|
||||
/**
|
||||
* Instance.
|
||||
*
|
||||
* @var Support
|
||||
*/
|
||||
private static $instance;
|
||||
|
||||
/**
|
||||
* Bootstrap.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param Config $config
|
||||
*/
|
||||
private function __construct(Config $config)
|
||||
{
|
||||
$this->baseUri = Alipay::URL[$config->get('mode', Alipay::MODE_NORMAL)];
|
||||
$this->config = $config;
|
||||
|
||||
$this->setHttpOptions();
|
||||
}
|
||||
|
||||
/**
|
||||
* __get.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param $key
|
||||
*
|
||||
* @return mixed|null|Config
|
||||
*/
|
||||
public function __get($key)
|
||||
{
|
||||
return $this->getConfig($key);
|
||||
}
|
||||
|
||||
/**
|
||||
* create.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param Config $config
|
||||
*
|
||||
* @return Support
|
||||
*/
|
||||
public static function create(Config $config)
|
||||
{
|
||||
if (php_sapi_name() === 'cli' || !(self::$instance instanceof self)) {
|
||||
self::$instance = new self($config);
|
||||
}
|
||||
|
||||
return self::$instance;
|
||||
}
|
||||
|
||||
/**
|
||||
* clear.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @return void
|
||||
*/
|
||||
public function clear()
|
||||
{
|
||||
self::$instance = null;
|
||||
}
|
||||
|
||||
/**
|
||||
* Get Alipay API result.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param array $data
|
||||
*
|
||||
* @throws GatewayException
|
||||
* @throws InvalidConfigException
|
||||
* @throws InvalidSignException
|
||||
*
|
||||
* @return Collection
|
||||
*/
|
||||
public static function requestApi(array $data): Collection
|
||||
{
|
||||
Events::dispatch(new Events\ApiRequesting('Alipay', '', self::$instance->getBaseUri(), $data));
|
||||
|
||||
$data = array_filter($data, function ($value) {
|
||||
return ($value == '' || is_null($value)) ? false : true;
|
||||
});
|
||||
|
||||
$result = json_decode(self::$instance->post('', $data), true);
|
||||
|
||||
Events::dispatch(new Events\ApiRequested('Alipay', '', self::$instance->getBaseUri(), $result));
|
||||
|
||||
return self::processingApiResult($data, $result);
|
||||
}
|
||||
|
||||
/**
|
||||
* Generate sign.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param array $params
|
||||
*
|
||||
* @throws InvalidConfigException
|
||||
*
|
||||
* @return string
|
||||
*/
|
||||
public static function generateSign(array $params): string
|
||||
{
|
||||
$privateKey = self::$instance->private_key;
|
||||
|
||||
if (is_null($privateKey)) {
|
||||
throw new InvalidConfigException('Missing Alipay Config -- [private_key]');
|
||||
}
|
||||
|
||||
if (Str::endsWith($privateKey, '.pem')) {
|
||||
$privateKey = openssl_pkey_get_private(
|
||||
Str::startsWith($privateKey, 'file://') ? $privateKey : 'file://'.$privateKey
|
||||
);
|
||||
} else {
|
||||
$privateKey = "-----BEGIN RSA PRIVATE KEY-----\n".
|
||||
wordwrap($privateKey, 64, "\n", true).
|
||||
"\n-----END RSA PRIVATE KEY-----";
|
||||
}
|
||||
|
||||
openssl_sign(self::getSignContent($params), $sign, $privateKey, OPENSSL_ALGO_SHA256);
|
||||
|
||||
$sign = base64_encode($sign);
|
||||
|
||||
Log::debug('Alipay Generate Sign', [$params, $sign]);
|
||||
|
||||
if (is_resource($privateKey)) {
|
||||
openssl_free_key($privateKey);
|
||||
}
|
||||
|
||||
return $sign;
|
||||
}
|
||||
|
||||
/**
|
||||
* Verify sign.
|
||||
*
|
||||
* @author yansongda <me@yansonga.cn>
|
||||
*
|
||||
* @param array $data
|
||||
* @param bool $sync
|
||||
* @param string|null $sign
|
||||
*
|
||||
* @throws InvalidConfigException
|
||||
*
|
||||
* @return bool
|
||||
*/
|
||||
public static function verifySign(array $data, $sync = false, $sign = null): bool
|
||||
{
|
||||
$publicKey = self::$instance->ali_public_key;
|
||||
|
||||
if (is_null($publicKey)) {
|
||||
throw new InvalidConfigException('Missing Alipay Config -- [ali_public_key]');
|
||||
}
|
||||
|
||||
if (Str::endsWith($publicKey, '.pem')) {
|
||||
$publicKey = openssl_pkey_get_public($publicKey);
|
||||
} else {
|
||||
$publicKey = "-----BEGIN PUBLIC KEY-----\n".
|
||||
wordwrap($publicKey, 64, "\n", true).
|
||||
"\n-----END PUBLIC KEY-----";
|
||||
}
|
||||
|
||||
$sign = $sign ?? $data['sign'];
|
||||
|
||||
$toVerify = $sync ? json_encode($data, JSON_UNESCAPED_UNICODE) : self::getSignContent($data, true);
|
||||
|
||||
$isVerify = openssl_verify($toVerify, base64_decode($sign), $publicKey, OPENSSL_ALGO_SHA256) === 1;
|
||||
|
||||
if (is_resource($publicKey)) {
|
||||
openssl_free_key($publicKey);
|
||||
}
|
||||
|
||||
return $isVerify;
|
||||
}
|
||||
|
||||
/**
|
||||
* Get signContent that is to be signed.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param array $data
|
||||
* @param bool $verify
|
||||
*
|
||||
* @return string
|
||||
*/
|
||||
public static function getSignContent(array $data, $verify = false): string
|
||||
{
|
||||
ksort($data);
|
||||
|
||||
$stringToBeSigned = '';
|
||||
foreach ($data as $k => $v) {
|
||||
if ($verify && $k != 'sign' && $k != 'sign_type') {
|
||||
$stringToBeSigned .= $k.'='.$v.'&';
|
||||
}
|
||||
if (!$verify && $v !== '' && !is_null($v) && $k != 'sign' && '@' != substr($v, 0, 1)) {
|
||||
$stringToBeSigned .= $k.'='.$v.'&';
|
||||
}
|
||||
}
|
||||
|
||||
Log::debug('Alipay Generate Sign Content Before Trim', [$data, $stringToBeSigned]);
|
||||
|
||||
return trim($stringToBeSigned, '&');
|
||||
}
|
||||
|
||||
/**
|
||||
* Convert encoding.
|
||||
*
|
||||
* @author yansongda <me@yansonga.cn>
|
||||
*
|
||||
* @param string|array $data
|
||||
* @param string $to
|
||||
* @param string $from
|
||||
*
|
||||
* @return array
|
||||
*/
|
||||
public static function encoding($data, $to = 'utf-8', $from = 'gb2312'): array
|
||||
{
|
||||
return Arr::encoding((array) $data, $to, $from);
|
||||
}
|
||||
|
||||
/**
|
||||
* Get service config.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param null|string $key
|
||||
* @param null|mixed $default
|
||||
*
|
||||
* @return mixed|null
|
||||
*/
|
||||
public function getConfig($key = null, $default = null)
|
||||
{
|
||||
if (is_null($key)) {
|
||||
return $this->config->all();
|
||||
}
|
||||
|
||||
if ($this->config->has($key)) {
|
||||
return $this->config[$key];
|
||||
}
|
||||
|
||||
return $default;
|
||||
}
|
||||
|
||||
/**
|
||||
* Get Base Uri.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @return string
|
||||
*/
|
||||
public function getBaseUri()
|
||||
{
|
||||
return $this->baseUri;
|
||||
}
|
||||
|
||||
/**
|
||||
* processingApiResult.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param $data
|
||||
* @param $result
|
||||
*
|
||||
* @throws GatewayException
|
||||
* @throws InvalidConfigException
|
||||
* @throws InvalidSignException
|
||||
*
|
||||
* @return Collection
|
||||
*/
|
||||
protected static function processingApiResult($data, $result): Collection
|
||||
{
|
||||
$method = str_replace('.', '_', $data['method']).'_response';
|
||||
|
||||
if (!isset($result['sign']) || $result[$method]['code'] != '10000') {
|
||||
throw new GatewayException(
|
||||
'Get Alipay API Error:'.$result[$method]['msg'].
|
||||
(isset($result[$method]['sub_code']) ? (' - '.$result[$method]['sub_code']) : ''),
|
||||
$result
|
||||
);
|
||||
}
|
||||
|
||||
if (self::verifySign($result[$method], true, $result['sign'])) {
|
||||
return new Collection($result[$method]);
|
||||
}
|
||||
|
||||
Events::dispatch(new Events\SignFailed('Alipay', '', $result));
|
||||
|
||||
throw new InvalidSignException('Alipay Sign Verify FAILED', $result);
|
||||
}
|
||||
|
||||
/**
|
||||
* Set Http options.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @return self
|
||||
*/
|
||||
protected function setHttpOptions(): self
|
||||
{
|
||||
if ($this->config->has('http') && is_array($this->config->get('http'))) {
|
||||
$this->config->forget('http.base_uri');
|
||||
$this->httpOptions = $this->config->get('http');
|
||||
}
|
||||
|
||||
return $this;
|
||||
}
|
||||
}
|
||||
@ -1,58 +0,0 @@
|
||||
<?php
|
||||
|
||||
namespace Yansongda\Pay\Gateways\Alipay;
|
||||
|
||||
use Yansongda\Pay\Contracts\GatewayInterface;
|
||||
use Yansongda\Pay\Events;
|
||||
use Yansongda\Pay\Exceptions\GatewayException;
|
||||
use Yansongda\Pay\Exceptions\InvalidConfigException;
|
||||
use Yansongda\Pay\Exceptions\InvalidSignException;
|
||||
use Yansongda\Supports\Collection;
|
||||
|
||||
class TransferGateway implements GatewayInterface
|
||||
{
|
||||
/**
|
||||
* Pay an order.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param string $endpoint
|
||||
* @param array $payload
|
||||
*
|
||||
* @throws GatewayException
|
||||
* @throws InvalidConfigException
|
||||
* @throws InvalidSignException
|
||||
*
|
||||
* @return Collection
|
||||
*/
|
||||
public function pay($endpoint, array $payload): Collection
|
||||
{
|
||||
$payload['method'] = 'alipay.fund.trans.toaccount.transfer';
|
||||
$payload['biz_content'] = json_encode(array_merge(
|
||||
json_decode($payload['biz_content'], true),
|
||||
['product_code' => '']
|
||||
));
|
||||
$payload['sign'] = Support::generateSign($payload);
|
||||
|
||||
Events::dispatch(new Events\PayStarted('Alipay', 'Transfer', $endpoint, $payload));
|
||||
|
||||
return Support::requestApi($payload);
|
||||
}
|
||||
|
||||
/**
|
||||
* Find.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param $order
|
||||
*
|
||||
* @return array
|
||||
*/
|
||||
public function find($order): array
|
||||
{
|
||||
return [
|
||||
'method' => 'alipay.fund.trans.order.query',
|
||||
'biz_content' => json_encode(is_array($order) ? $order : ['out_biz_no' => $order]),
|
||||
];
|
||||
}
|
||||
}
|
||||
@ -1,30 +0,0 @@
|
||||
<?php
|
||||
|
||||
namespace Yansongda\Pay\Gateways\Alipay;
|
||||
|
||||
class WapGateway extends WebGateway
|
||||
{
|
||||
/**
|
||||
* Get method config.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @return string
|
||||
*/
|
||||
protected function getMethod(): string
|
||||
{
|
||||
return 'alipay.trade.wap.pay';
|
||||
}
|
||||
|
||||
/**
|
||||
* Get productCode config.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @return string
|
||||
*/
|
||||
protected function getProductCode(): string
|
||||
{
|
||||
return 'QUICK_WAP_WAY';
|
||||
}
|
||||
}
|
||||
@ -1,111 +0,0 @@
|
||||
<?php
|
||||
|
||||
namespace Yansongda\Pay\Gateways\Alipay;
|
||||
|
||||
use Symfony\Component\HttpFoundation\RedirectResponse;
|
||||
use Symfony\Component\HttpFoundation\Response;
|
||||
use Yansongda\Pay\Contracts\GatewayInterface;
|
||||
use Yansongda\Pay\Events;
|
||||
use Yansongda\Pay\Exceptions\InvalidConfigException;
|
||||
|
||||
class WebGateway implements GatewayInterface
|
||||
{
|
||||
/**
|
||||
* Pay an order.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param string $endpoint
|
||||
* @param array $payload
|
||||
*
|
||||
* @throws InvalidConfigException
|
||||
*
|
||||
* @return Response
|
||||
*/
|
||||
public function pay($endpoint, array $payload): Response
|
||||
{
|
||||
$biz_array = json_decode($payload['biz_content'], true);
|
||||
$biz_array['product_code'] = $this->getProductCode();
|
||||
|
||||
$method = $biz_array['http_method'] ?? 'POST';
|
||||
|
||||
unset($biz_array['http_method']);
|
||||
|
||||
$payload['method'] = $this->getMethod();
|
||||
$payload['biz_content'] = json_encode($biz_array);
|
||||
$payload['sign'] = Support::generateSign($payload);
|
||||
|
||||
Events::dispatch(new Events\PayStarted('Alipay', 'Web/Wap', $endpoint, $payload));
|
||||
|
||||
return $this->buildPayHtml($endpoint, $payload, $method);
|
||||
}
|
||||
|
||||
/**
|
||||
* Find.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param $order
|
||||
*
|
||||
* @return array
|
||||
*/
|
||||
public function find($order): array
|
||||
{
|
||||
return [
|
||||
'method' => 'alipay.trade.query',
|
||||
'biz_content' => json_encode(is_array($order) ? $order : ['out_trade_no' => $order]),
|
||||
];
|
||||
}
|
||||
|
||||
/**
|
||||
* Build Html response.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param string $endpoint
|
||||
* @param array $payload
|
||||
* @param string $method
|
||||
*
|
||||
* @return Response
|
||||
*/
|
||||
protected function buildPayHtml($endpoint, $payload, $method = 'POST'): Response
|
||||
{
|
||||
if (strtoupper($method) === 'GET') {
|
||||
return RedirectResponse::create($endpoint.'&'.http_build_query($payload));
|
||||
}
|
||||
|
||||
$sHtml = "<form id='alipay_submit' name='alipay_submit' action='".$endpoint."' method='".$method."'>";
|
||||
foreach ($payload as $key => $val) {
|
||||
$val = str_replace("'", ''', $val);
|
||||
$sHtml .= "<input type='hidden' name='".$key."' value='".$val."'/>";
|
||||
}
|
||||
$sHtml .= "<input type='submit' value='ok' style='display:none;'></form>";
|
||||
$sHtml .= "<script>document.forms['alipay_submit'].submit();</script>";
|
||||
|
||||
return Response::create($sHtml);
|
||||
}
|
||||
|
||||
/**
|
||||
* Get method config.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @return string
|
||||
*/
|
||||
protected function getMethod(): string
|
||||
{
|
||||
return 'alipay.trade.page.pay';
|
||||
}
|
||||
|
||||
/**
|
||||
* Get productCode config.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @return string
|
||||
*/
|
||||
protected function getProductCode(): string
|
||||
{
|
||||
return 'FAST_INSTANT_TRADE_PAY';
|
||||
}
|
||||
}
|
||||
@ -1,387 +0,0 @@
|
||||
<?php
|
||||
|
||||
namespace Yansongda\Pay\Gateways;
|
||||
|
||||
use Exception;
|
||||
use Symfony\Component\HttpFoundation\RedirectResponse;
|
||||
use Symfony\Component\HttpFoundation\Request;
|
||||
use Symfony\Component\HttpFoundation\Response;
|
||||
use Yansongda\Pay\Contracts\GatewayApplicationInterface;
|
||||
use Yansongda\Pay\Contracts\GatewayInterface;
|
||||
use Yansongda\Pay\Events;
|
||||
use Yansongda\Pay\Exceptions\GatewayException;
|
||||
use Yansongda\Pay\Exceptions\InvalidArgumentException;
|
||||
use Yansongda\Pay\Exceptions\InvalidGatewayException;
|
||||
use Yansongda\Pay\Exceptions\InvalidSignException;
|
||||
use Yansongda\Pay\Gateways\Wechat\Support;
|
||||
use Yansongda\Pay\Log;
|
||||
use Yansongda\Supports\Collection;
|
||||
use Yansongda\Supports\Config;
|
||||
use Yansongda\Supports\Str;
|
||||
|
||||
/**
|
||||
* @method Response app(array $config) APP 支付
|
||||
* @method Collection groupRedpack(array $config) 分裂红包
|
||||
* @method Collection miniapp(array $config) 小程序支付
|
||||
* @method Collection mp(array $config) 公众号支付
|
||||
* @method Collection pos(array $config) 刷卡支付
|
||||
* @method Collection redpack(array $config) 普通红包
|
||||
* @method Collection scan(array $config) 扫码支付
|
||||
* @method Collection transfer(array $config) 企业付款
|
||||
* @method RedirectResponse wap(array $config) H5 支付
|
||||
*/
|
||||
class Wechat implements GatewayApplicationInterface
|
||||
{
|
||||
/**
|
||||
* 普通模式.
|
||||
*/
|
||||
const MODE_NORMAL = 'normal';
|
||||
|
||||
/**
|
||||
* 沙箱模式.
|
||||
*/
|
||||
const MODE_DEV = 'dev';
|
||||
|
||||
/**
|
||||
* 香港钱包 API.
|
||||
*/
|
||||
const MODE_HK = 'hk';
|
||||
|
||||
/**
|
||||
* 境外 API.
|
||||
*/
|
||||
const MODE_US = 'us';
|
||||
|
||||
/**
|
||||
* 服务商模式.
|
||||
*/
|
||||
const MODE_SERVICE = 'service';
|
||||
|
||||
/**
|
||||
* Const url.
|
||||
*/
|
||||
const URL = [
|
||||
self::MODE_NORMAL => 'https://api.mch.weixin.qq.com/',
|
||||
self::MODE_DEV => 'https://api.mch.weixin.qq.com/sandboxnew/',
|
||||
self::MODE_HK => 'https://apihk.mch.weixin.qq.com/',
|
||||
self::MODE_SERVICE => 'https://api.mch.weixin.qq.com/',
|
||||
self::MODE_US => 'https://apius.mch.weixin.qq.com/',
|
||||
];
|
||||
|
||||
/**
|
||||
* Wechat payload.
|
||||
*
|
||||
* @var array
|
||||
*/
|
||||
protected $payload;
|
||||
|
||||
/**
|
||||
* Wechat gateway.
|
||||
*
|
||||
* @var string
|
||||
*/
|
||||
protected $gateway;
|
||||
|
||||
/**
|
||||
* Bootstrap.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param Config $config
|
||||
*
|
||||
* @throws Exception
|
||||
*/
|
||||
public function __construct(Config $config)
|
||||
{
|
||||
$this->gateway = Support::create($config)->getBaseUri();
|
||||
$this->payload = [
|
||||
'appid' => $config->get('app_id', ''),
|
||||
'mch_id' => $config->get('mch_id', ''),
|
||||
'nonce_str' => Str::random(),
|
||||
'notify_url' => $config->get('notify_url', ''),
|
||||
'sign' => '',
|
||||
'trade_type' => '',
|
||||
'spbill_create_ip' => Request::createFromGlobals()->getClientIp(),
|
||||
];
|
||||
|
||||
if ($config->get('mode', self::MODE_NORMAL) === static::MODE_SERVICE) {
|
||||
$this->payload = array_merge($this->payload, [
|
||||
'sub_mch_id' => $config->get('sub_mch_id'),
|
||||
'sub_appid' => $config->get('sub_app_id', ''),
|
||||
]);
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Magic pay.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param string $method
|
||||
* @param string $params
|
||||
*
|
||||
* @throws InvalidGatewayException
|
||||
*
|
||||
* @return Response|Collection
|
||||
*/
|
||||
public function __call($method, $params)
|
||||
{
|
||||
return self::pay($method, ...$params);
|
||||
}
|
||||
|
||||
/**
|
||||
* Pay an order.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param string $gateway
|
||||
* @param array $params
|
||||
*
|
||||
* @throws InvalidGatewayException
|
||||
*
|
||||
* @return Response|Collection
|
||||
*/
|
||||
public function pay($gateway, $params = [])
|
||||
{
|
||||
Events::dispatch(new Events\PayStarting('Wechat', $gateway, $params));
|
||||
|
||||
$this->payload = array_merge($this->payload, $params);
|
||||
|
||||
$gateway = get_class($this).'\\'.Str::studly($gateway).'Gateway';
|
||||
|
||||
if (class_exists($gateway)) {
|
||||
return $this->makePay($gateway);
|
||||
}
|
||||
|
||||
throw new InvalidGatewayException("Pay Gateway [{$gateway}] Not Exists");
|
||||
}
|
||||
|
||||
/**
|
||||
* Verify data.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param string|null $content
|
||||
* @param bool $refund
|
||||
*
|
||||
* @throws InvalidSignException
|
||||
* @throws InvalidArgumentException
|
||||
*
|
||||
* @return Collection
|
||||
*/
|
||||
public function verify($content = null, bool $refund = false): Collection
|
||||
{
|
||||
$content = $content ?? Request::createFromGlobals()->getContent();
|
||||
|
||||
Events::dispatch(new Events\RequestReceived('Wechat', '', [$content]));
|
||||
|
||||
$data = Support::fromXml($content);
|
||||
if ($refund) {
|
||||
$decrypt_data = Support::decryptRefundContents($data['req_info']);
|
||||
$data = array_merge(Support::fromXml($decrypt_data), $data);
|
||||
}
|
||||
|
||||
Log::debug('Resolved The Received Wechat Request Data', $data);
|
||||
|
||||
if ($refund || Support::generateSign($data) === $data['sign']) {
|
||||
return new Collection($data);
|
||||
}
|
||||
|
||||
Events::dispatch(new Events\SignFailed('Wechat', '', $data));
|
||||
|
||||
throw new InvalidSignException('Wechat Sign Verify FAILED', $data);
|
||||
}
|
||||
|
||||
/**
|
||||
* Query an order.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param string|array $order
|
||||
* @param string $type
|
||||
*
|
||||
* @throws GatewayException
|
||||
* @throws InvalidSignException
|
||||
* @throws InvalidArgumentException
|
||||
*
|
||||
* @return Collection
|
||||
*/
|
||||
public function find($order, string $type = 'wap'): Collection
|
||||
{
|
||||
if ($type != 'wap') {
|
||||
unset($this->payload['spbill_create_ip']);
|
||||
}
|
||||
|
||||
$gateway = get_class($this).'\\'.Str::studly($type).'Gateway';
|
||||
|
||||
if (!class_exists($gateway) || !is_callable([new $gateway(), 'find'])) {
|
||||
throw new GatewayException("{$gateway} Done Not Exist Or Done Not Has FIND Method");
|
||||
}
|
||||
|
||||
$config = call_user_func([new $gateway(), 'find'], $order);
|
||||
|
||||
$this->payload = Support::filterPayload($this->payload, $config['order']);
|
||||
|
||||
Events::dispatch(new Events\MethodCalled('Wechat', 'Find', $this->gateway, $this->payload));
|
||||
|
||||
return Support::requestApi(
|
||||
$config['endpoint'],
|
||||
$this->payload,
|
||||
$config['cert']
|
||||
);
|
||||
}
|
||||
|
||||
/**
|
||||
* Refund an order.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param array $order
|
||||
*
|
||||
* @throws GatewayException
|
||||
* @throws InvalidSignException
|
||||
* @throws InvalidArgumentException
|
||||
*
|
||||
* @return Collection
|
||||
*/
|
||||
public function refund(array $order): Collection
|
||||
{
|
||||
$this->payload = Support::filterPayload($this->payload, $order, true);
|
||||
|
||||
Events::dispatch(new Events\MethodCalled('Wechat', 'Refund', $this->gateway, $this->payload));
|
||||
|
||||
return Support::requestApi(
|
||||
'secapi/pay/refund',
|
||||
$this->payload,
|
||||
true
|
||||
);
|
||||
}
|
||||
|
||||
/**
|
||||
* Cancel an order.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param array $order
|
||||
*
|
||||
* @throws GatewayException
|
||||
* @throws InvalidSignException
|
||||
* @throws InvalidArgumentException
|
||||
*
|
||||
* @return Collection
|
||||
*/
|
||||
public function cancel($order): Collection
|
||||
{
|
||||
unset($this->payload['spbill_create_ip']);
|
||||
|
||||
$this->payload = Support::filterPayload($this->payload, $order, true);
|
||||
|
||||
Events::dispatch(new Events\MethodCalled('Wechat', 'Cancel', $this->gateway, $this->payload));
|
||||
|
||||
return Support::requestApi(
|
||||
'secapi/pay/reverse',
|
||||
$this->payload,
|
||||
true
|
||||
);
|
||||
}
|
||||
|
||||
/**
|
||||
* Close an order.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param string|array $order
|
||||
*
|
||||
* @throws GatewayException
|
||||
* @throws InvalidSignException
|
||||
* @throws InvalidArgumentException
|
||||
*
|
||||
* @return Collection
|
||||
*/
|
||||
public function close($order): Collection
|
||||
{
|
||||
unset($this->payload['spbill_create_ip']);
|
||||
|
||||
$this->payload = Support::filterPayload($this->payload, $order);
|
||||
|
||||
Events::dispatch(new Events\MethodCalled('Wechat', 'Close', $this->gateway, $this->payload));
|
||||
|
||||
return Support::requestApi('pay/closeorder', $this->payload);
|
||||
}
|
||||
|
||||
/**
|
||||
* Echo success to server.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @throws InvalidArgumentException
|
||||
*
|
||||
* @return Response
|
||||
*/
|
||||
public function success(): Response
|
||||
{
|
||||
Events::dispatch(new Events\MethodCalled('Wechat', 'Success', $this->gateway));
|
||||
|
||||
return Response::create(
|
||||
Support::toXml(['return_code' => 'SUCCESS', 'return_msg' => 'OK']),
|
||||
200,
|
||||
['Content-Type' => 'application/xml']
|
||||
);
|
||||
}
|
||||
|
||||
/**
|
||||
* Download the bill.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param array $params
|
||||
*
|
||||
* @throws GatewayException
|
||||
* @throws InvalidArgumentException
|
||||
*
|
||||
* @return string
|
||||
*/
|
||||
public function download(array $params): string
|
||||
{
|
||||
unset($this->payload['spbill_create_ip']);
|
||||
|
||||
$this->payload = Support::filterPayload($this->payload, $params, true);
|
||||
|
||||
Events::dispatch(new Events\MethodCalled('Wechat', 'Download', $this->gateway, $this->payload));
|
||||
|
||||
$result = Support::getInstance()->post(
|
||||
'pay/downloadbill',
|
||||
Support::getInstance()->toXml($this->payload)
|
||||
);
|
||||
|
||||
if (is_array($result)) {
|
||||
throw new GatewayException('Get Wechat API Error: '.$result['return_msg'], $result);
|
||||
}
|
||||
|
||||
return $result;
|
||||
}
|
||||
|
||||
/**
|
||||
* Make pay gateway.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param string $gateway
|
||||
*
|
||||
* @throws InvalidGatewayException
|
||||
*
|
||||
* @return Response|Collection
|
||||
*/
|
||||
protected function makePay($gateway)
|
||||
{
|
||||
$app = new $gateway();
|
||||
|
||||
if ($app instanceof GatewayInterface) {
|
||||
return $app->pay($this->gateway, array_filter($this->payload, function ($value) {
|
||||
return $value !== '' && !is_null($value);
|
||||
}));
|
||||
}
|
||||
|
||||
throw new InvalidGatewayException("Pay Gateway [{$gateway}] Must Be An Instance Of GatewayInterface");
|
||||
}
|
||||
}
|
||||
@ -1,67 +0,0 @@
|
||||
<?php
|
||||
|
||||
namespace Yansongda\Pay\Gateways\Wechat;
|
||||
|
||||
use Exception;
|
||||
use Symfony\Component\HttpFoundation\JsonResponse;
|
||||
use Symfony\Component\HttpFoundation\Response;
|
||||
use Yansongda\Pay\Events;
|
||||
use Yansongda\Pay\Exceptions\GatewayException;
|
||||
use Yansongda\Pay\Exceptions\InvalidArgumentException;
|
||||
use Yansongda\Pay\Exceptions\InvalidSignException;
|
||||
use Yansongda\Pay\Gateways\Wechat;
|
||||
use Yansongda\Supports\Str;
|
||||
|
||||
class AppGateway extends Gateway
|
||||
{
|
||||
/**
|
||||
* Pay an order.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param string $endpoint
|
||||
* @param array $payload
|
||||
*
|
||||
* @throws GatewayException
|
||||
* @throws InvalidArgumentException
|
||||
* @throws InvalidSignException
|
||||
* @throws Exception
|
||||
*
|
||||
* @return Response
|
||||
*/
|
||||
public function pay($endpoint, array $payload): Response
|
||||
{
|
||||
$payload['appid'] = Support::getInstance()->appid;
|
||||
$payload['trade_type'] = $this->getTradeType();
|
||||
|
||||
if ($this->mode === Wechat::MODE_SERVICE) {
|
||||
$payload['sub_appid'] = Support::getInstance()->sub_appid;
|
||||
}
|
||||
|
||||
$pay_request = [
|
||||
'appid' => $this->mode === Wechat::MODE_SERVICE ? $payload['sub_appid'] : $payload['appid'],
|
||||
'partnerid' => $this->mode === Wechat::MODE_SERVICE ? $payload['sub_mch_id'] : $payload['mch_id'],
|
||||
'prepayid' => $this->preOrder($payload)->get('prepay_id'),
|
||||
'timestamp' => strval(time()),
|
||||
'noncestr' => Str::random(),
|
||||
'package' => 'Sign=WXPay',
|
||||
];
|
||||
$pay_request['sign'] = Support::generateSign($pay_request);
|
||||
|
||||
Events::dispatch(new Events\PayStarted('Wechat', 'App', $endpoint, $pay_request));
|
||||
|
||||
return JsonResponse::create($pay_request);
|
||||
}
|
||||
|
||||
/**
|
||||
* Get trade type config.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @return string
|
||||
*/
|
||||
protected function getTradeType(): string
|
||||
{
|
||||
return 'APP';
|
||||
}
|
||||
}
|
||||
@ -1,93 +0,0 @@
|
||||
<?php
|
||||
|
||||
namespace Yansongda\Pay\Gateways\Wechat;
|
||||
|
||||
use Yansongda\Pay\Contracts\GatewayInterface;
|
||||
use Yansongda\Pay\Events;
|
||||
use Yansongda\Pay\Exceptions\GatewayException;
|
||||
use Yansongda\Pay\Exceptions\InvalidArgumentException;
|
||||
use Yansongda\Pay\Exceptions\InvalidSignException;
|
||||
use Yansongda\Supports\Collection;
|
||||
|
||||
abstract class Gateway implements GatewayInterface
|
||||
{
|
||||
/**
|
||||
* Mode.
|
||||
*
|
||||
* @var string
|
||||
*/
|
||||
protected $mode;
|
||||
|
||||
/**
|
||||
* Bootstrap.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @throws InvalidArgumentException
|
||||
*/
|
||||
public function __construct()
|
||||
{
|
||||
$this->mode = Support::getInstance()->mode;
|
||||
}
|
||||
|
||||
/**
|
||||
* Pay an order.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param string $endpoint
|
||||
* @param array $payload
|
||||
*
|
||||
* @return Collection
|
||||
*/
|
||||
abstract public function pay($endpoint, array $payload);
|
||||
|
||||
/**
|
||||
* Find.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param string|array $order
|
||||
*
|
||||
* @return array
|
||||
*/
|
||||
public function find($order): array
|
||||
{
|
||||
return [
|
||||
'endpoint' => 'pay/orderquery',
|
||||
'order' => is_array($order) ? $order : ['out_trade_no' => $order],
|
||||
'cert' => false,
|
||||
];
|
||||
}
|
||||
|
||||
/**
|
||||
* Get trade type config.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @return string
|
||||
*/
|
||||
abstract protected function getTradeType();
|
||||
|
||||
/**
|
||||
* Schedule an order.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param array $payload
|
||||
*
|
||||
* @throws GatewayException
|
||||
* @throws InvalidArgumentException
|
||||
* @throws InvalidSignException
|
||||
*
|
||||
* @return Collection
|
||||
*/
|
||||
protected function preOrder($payload): Collection
|
||||
{
|
||||
$payload['sign'] = Support::generateSign($payload);
|
||||
|
||||
Events::dispatch(new Events\MethodCalled('Wechat', 'PreOrder', '', $payload));
|
||||
|
||||
return Support::requestApi('pay/unifiedorder', $payload);
|
||||
}
|
||||
}
|
||||
@ -1,62 +0,0 @@
|
||||
<?php
|
||||
|
||||
namespace Yansongda\Pay\Gateways\Wechat;
|
||||
|
||||
use Yansongda\Pay\Events;
|
||||
use Yansongda\Pay\Exceptions\GatewayException;
|
||||
use Yansongda\Pay\Exceptions\InvalidArgumentException;
|
||||
use Yansongda\Pay\Exceptions\InvalidSignException;
|
||||
use Yansongda\Pay\Gateways\Wechat;
|
||||
use Yansongda\Supports\Collection;
|
||||
|
||||
class GroupRedpackGateway extends Gateway
|
||||
{
|
||||
/**
|
||||
* Pay an order.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param string $endpoint
|
||||
* @param array $payload
|
||||
*
|
||||
* @throws GatewayException
|
||||
* @throws InvalidArgumentException
|
||||
* @throws InvalidSignException
|
||||
*
|
||||
* @return Collection
|
||||
*/
|
||||
public function pay($endpoint, array $payload): Collection
|
||||
{
|
||||
$payload['wxappid'] = $payload['appid'];
|
||||
$payload['amt_type'] = 'ALL_RAND';
|
||||
|
||||
if ($this->mode === Wechat::MODE_SERVICE) {
|
||||
$payload['msgappid'] = $payload['appid'];
|
||||
}
|
||||
|
||||
unset($payload['appid'], $payload['trade_type'],
|
||||
$payload['notify_url'], $payload['spbill_create_ip']);
|
||||
|
||||
$payload['sign'] = Support::generateSign($payload);
|
||||
|
||||
Events::dispatch(new Events\PayStarted('Wechat', 'Group Redpack', $endpoint, $payload));
|
||||
|
||||
return Support::requestApi(
|
||||
'mmpaymkttransfers/sendgroupredpack',
|
||||
$payload,
|
||||
true
|
||||
);
|
||||
}
|
||||
|
||||
/**
|
||||
* Get trade type config.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @return string
|
||||
*/
|
||||
protected function getTradeType(): string
|
||||
{
|
||||
return '';
|
||||
}
|
||||
}
|
||||
@ -1,38 +0,0 @@
|
||||
<?php
|
||||
|
||||
namespace Yansongda\Pay\Gateways\Wechat;
|
||||
|
||||
use Yansongda\Pay\Exceptions\GatewayException;
|
||||
use Yansongda\Pay\Exceptions\InvalidArgumentException;
|
||||
use Yansongda\Pay\Exceptions\InvalidSignException;
|
||||
use Yansongda\Pay\Gateways\Wechat;
|
||||
use Yansongda\Supports\Collection;
|
||||
|
||||
class MiniappGateway extends MpGateway
|
||||
{
|
||||
/**
|
||||
* Pay an order.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param string $endpoint
|
||||
* @param array $payload
|
||||
*
|
||||
* @throws GatewayException
|
||||
* @throws InvalidArgumentException
|
||||
* @throws InvalidSignException
|
||||
*
|
||||
* @return Collection
|
||||
*/
|
||||
public function pay($endpoint, array $payload): Collection
|
||||
{
|
||||
$payload['appid'] = Support::getInstance()->miniapp_id;
|
||||
|
||||
if ($this->mode === Wechat::MODE_SERVICE) {
|
||||
$payload['sub_appid'] = Support::getInstance()->sub_miniapp_id;
|
||||
$this->payRequestUseSubAppId = true;
|
||||
}
|
||||
|
||||
return parent::pay($endpoint, $payload);
|
||||
}
|
||||
}
|
||||
@ -1,64 +0,0 @@
|
||||
<?php
|
||||
|
||||
namespace Yansongda\Pay\Gateways\Wechat;
|
||||
|
||||
use Exception;
|
||||
use Yansongda\Pay\Events;
|
||||
use Yansongda\Pay\Exceptions\GatewayException;
|
||||
use Yansongda\Pay\Exceptions\InvalidArgumentException;
|
||||
use Yansongda\Pay\Exceptions\InvalidSignException;
|
||||
use Yansongda\Supports\Collection;
|
||||
use Yansongda\Supports\Str;
|
||||
|
||||
class MpGateway extends Gateway
|
||||
{
|
||||
/**
|
||||
* @var bool
|
||||
*/
|
||||
protected $payRequestUseSubAppId = false;
|
||||
|
||||
/**
|
||||
* Pay an order.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param string $endpoint
|
||||
* @param array $payload
|
||||
*
|
||||
* @throws GatewayException
|
||||
* @throws InvalidArgumentException
|
||||
* @throws InvalidSignException
|
||||
* @throws Exception
|
||||
*
|
||||
* @return Collection
|
||||
*/
|
||||
public function pay($endpoint, array $payload): Collection
|
||||
{
|
||||
$payload['trade_type'] = $this->getTradeType();
|
||||
|
||||
$pay_request = [
|
||||
'appId' => !$this->payRequestUseSubAppId ? $payload['appid'] : $payload['sub_appid'],
|
||||
'timeStamp' => strval(time()),
|
||||
'nonceStr' => Str::random(),
|
||||
'package' => 'prepay_id='.$this->preOrder($payload)->get('prepay_id'),
|
||||
'signType' => 'MD5',
|
||||
];
|
||||
$pay_request['paySign'] = Support::generateSign($pay_request);
|
||||
|
||||
Events::dispatch(new Events\PayStarted('Wechat', 'JSAPI', $endpoint, $pay_request));
|
||||
|
||||
return new Collection($pay_request);
|
||||
}
|
||||
|
||||
/**
|
||||
* Get trade type config.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @return string
|
||||
*/
|
||||
protected function getTradeType(): string
|
||||
{
|
||||
return 'JSAPI';
|
||||
}
|
||||
}
|
||||
@ -1,49 +0,0 @@
|
||||
<?php
|
||||
|
||||
namespace Yansongda\Pay\Gateways\Wechat;
|
||||
|
||||
use Yansongda\Pay\Events;
|
||||
use Yansongda\Pay\Exceptions\GatewayException;
|
||||
use Yansongda\Pay\Exceptions\InvalidArgumentException;
|
||||
use Yansongda\Pay\Exceptions\InvalidSignException;
|
||||
use Yansongda\Supports\Collection;
|
||||
|
||||
class PosGateway extends Gateway
|
||||
{
|
||||
/**
|
||||
* Pay an order.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param string $endpoint
|
||||
* @param array $payload
|
||||
*
|
||||
* @throws GatewayException
|
||||
* @throws InvalidArgumentException
|
||||
* @throws InvalidSignException
|
||||
*
|
||||
* @return Collection
|
||||
*/
|
||||
public function pay($endpoint, array $payload): Collection
|
||||
{
|
||||
unset($payload['trade_type'], $payload['notify_url']);
|
||||
|
||||
$payload['sign'] = Support::generateSign($payload);
|
||||
|
||||
Events::dispatch(new Events\PayStarted('Wechat', 'Pos', $endpoint, $payload));
|
||||
|
||||
return Support::requestApi('pay/micropay', $payload);
|
||||
}
|
||||
|
||||
/**
|
||||
* Get trade type config.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @return string
|
||||
*/
|
||||
protected function getTradeType(): string
|
||||
{
|
||||
return 'MICROPAY';
|
||||
}
|
||||
}
|
||||
@ -1,66 +0,0 @@
|
||||
<?php
|
||||
|
||||
namespace Yansongda\Pay\Gateways\Wechat;
|
||||
|
||||
use Symfony\Component\HttpFoundation\Request;
|
||||
use Yansongda\Pay\Events;
|
||||
use Yansongda\Pay\Exceptions\GatewayException;
|
||||
use Yansongda\Pay\Exceptions\InvalidArgumentException;
|
||||
use Yansongda\Pay\Exceptions\InvalidSignException;
|
||||
use Yansongda\Pay\Gateways\Wechat;
|
||||
use Yansongda\Supports\Collection;
|
||||
|
||||
class RedpackGateway extends Gateway
|
||||
{
|
||||
/**
|
||||
* Pay an order.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param string $endpoint
|
||||
* @param array $payload
|
||||
*
|
||||
* @throws GatewayException
|
||||
* @throws InvalidArgumentException
|
||||
* @throws InvalidSignException
|
||||
*
|
||||
* @return Collection
|
||||
*/
|
||||
public function pay($endpoint, array $payload): Collection
|
||||
{
|
||||
$payload['wxappid'] = $payload['appid'];
|
||||
|
||||
if (php_sapi_name() !== 'cli') {
|
||||
$payload['client_ip'] = Request::createFromGlobals()->server->get('SERVER_ADDR');
|
||||
}
|
||||
|
||||
if ($this->mode === Wechat::MODE_SERVICE) {
|
||||
$payload['msgappid'] = $payload['appid'];
|
||||
}
|
||||
|
||||
unset($payload['appid'], $payload['trade_type'],
|
||||
$payload['notify_url'], $payload['spbill_create_ip']);
|
||||
|
||||
$payload['sign'] = Support::generateSign($payload);
|
||||
|
||||
Events::dispatch(new Events\PayStarted('Wechat', 'Redpack', $endpoint, $payload));
|
||||
|
||||
return Support::requestApi(
|
||||
'mmpaymkttransfers/sendredpack',
|
||||
$payload,
|
||||
true
|
||||
);
|
||||
}
|
||||
|
||||
/**
|
||||
* Get trade type config.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @return string
|
||||
*/
|
||||
protected function getTradeType(): string
|
||||
{
|
||||
return '';
|
||||
}
|
||||
}
|
||||
@ -1,57 +0,0 @@
|
||||
<?php
|
||||
|
||||
namespace Yansongda\Pay\Gateways\Wechat;
|
||||
|
||||
use Yansongda\Pay\Exceptions\InvalidArgumentException;
|
||||
|
||||
class RefundGateway extends Gateway
|
||||
{
|
||||
/**
|
||||
* Find.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param $order
|
||||
*
|
||||
* @return array
|
||||
*/
|
||||
public function find($order): array
|
||||
{
|
||||
return [
|
||||
'endpoint' => 'pay/refundquery',
|
||||
'order' => is_array($order) ? $order : ['out_trade_no' => $order],
|
||||
'cert' => false,
|
||||
];
|
||||
}
|
||||
|
||||
/**
|
||||
* Pay an order.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param string $endpoint
|
||||
* @param array $payload
|
||||
*
|
||||
* @throws InvalidArgumentException
|
||||
*
|
||||
* @return void
|
||||
*/
|
||||
public function pay($endpoint, array $payload)
|
||||
{
|
||||
throw new InvalidArgumentException('Not Support Refund In Pay');
|
||||
}
|
||||
|
||||
/**
|
||||
* Get trade type config.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @throws InvalidArgumentException
|
||||
*
|
||||
* @return void
|
||||
*/
|
||||
protected function getTradeType()
|
||||
{
|
||||
throw new InvalidArgumentException('Not Support Refund In Pay');
|
||||
}
|
||||
}
|
||||
@ -1,49 +0,0 @@
|
||||
<?php
|
||||
|
||||
namespace Yansongda\Pay\Gateways\Wechat;
|
||||
|
||||
use Symfony\Component\HttpFoundation\Request;
|
||||
use Yansongda\Pay\Events;
|
||||
use Yansongda\Pay\Exceptions\GatewayException;
|
||||
use Yansongda\Pay\Exceptions\InvalidArgumentException;
|
||||
use Yansongda\Pay\Exceptions\InvalidSignException;
|
||||
use Yansongda\Supports\Collection;
|
||||
|
||||
class ScanGateway extends Gateway
|
||||
{
|
||||
/**
|
||||
* Pay an order.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param string $endpoint
|
||||
* @param array $payload
|
||||
*
|
||||
* @throws GatewayException
|
||||
* @throws InvalidArgumentException
|
||||
* @throws InvalidSignException
|
||||
*
|
||||
* @return Collection
|
||||
*/
|
||||
public function pay($endpoint, array $payload): Collection
|
||||
{
|
||||
$payload['spbill_create_ip'] = Request::createFromGlobals()->server->get('SERVER_ADDR');
|
||||
$payload['trade_type'] = $this->getTradeType();
|
||||
|
||||
Events::dispatch(new Events\PayStarted('Wechat', 'Scan', $endpoint, $payload));
|
||||
|
||||
return $this->preOrder($payload);
|
||||
}
|
||||
|
||||
/**
|
||||
* Get trade type config.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @return string
|
||||
*/
|
||||
protected function getTradeType(): string
|
||||
{
|
||||
return 'NATIVE';
|
||||
}
|
||||
}
|
||||
@ -1,480 +0,0 @@
|
||||
<?php
|
||||
|
||||
namespace Yansongda\Pay\Gateways\Wechat;
|
||||
|
||||
use Exception;
|
||||
use Yansongda\Pay\Events;
|
||||
use Yansongda\Pay\Exceptions\BusinessException;
|
||||
use Yansongda\Pay\Exceptions\GatewayException;
|
||||
use Yansongda\Pay\Exceptions\InvalidArgumentException;
|
||||
use Yansongda\Pay\Exceptions\InvalidSignException;
|
||||
use Yansongda\Pay\Gateways\Wechat;
|
||||
use Yansongda\Pay\Log;
|
||||
use Yansongda\Supports\Collection;
|
||||
use Yansongda\Supports\Config;
|
||||
use Yansongda\Supports\Str;
|
||||
use Yansongda\Supports\Traits\HasHttpRequest;
|
||||
|
||||
/**
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @property string appid
|
||||
* @property string app_id
|
||||
* @property string miniapp_id
|
||||
* @property string sub_appid
|
||||
* @property string sub_app_id
|
||||
* @property string sub_miniapp_id
|
||||
* @property string mch_id
|
||||
* @property string sub_mch_id
|
||||
* @property string key
|
||||
* @property string return_url
|
||||
* @property string cert_client
|
||||
* @property string cert_key
|
||||
* @property array log
|
||||
* @property array http
|
||||
* @property string mode
|
||||
*/
|
||||
class Support
|
||||
{
|
||||
use HasHttpRequest;
|
||||
|
||||
/**
|
||||
* Wechat gateway.
|
||||
*
|
||||
* @var string
|
||||
*/
|
||||
protected $baseUri;
|
||||
|
||||
/**
|
||||
* Config.
|
||||
*
|
||||
* @var Config
|
||||
*/
|
||||
protected $config;
|
||||
|
||||
/**
|
||||
* Instance.
|
||||
*
|
||||
* @var Support
|
||||
*/
|
||||
private static $instance;
|
||||
|
||||
/**
|
||||
* Bootstrap.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param Config $config
|
||||
*/
|
||||
private function __construct(Config $config)
|
||||
{
|
||||
$this->baseUri = Wechat::URL[$config->get('mode', Wechat::MODE_NORMAL)];
|
||||
$this->config = $config;
|
||||
|
||||
$this->setHttpOptions();
|
||||
}
|
||||
|
||||
/**
|
||||
* __get.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param $key
|
||||
*
|
||||
* @return mixed|null|Config
|
||||
*/
|
||||
public function __get($key)
|
||||
{
|
||||
return $this->getConfig($key);
|
||||
}
|
||||
|
||||
/**
|
||||
* create.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param Config $config
|
||||
*
|
||||
* @throws GatewayException
|
||||
* @throws InvalidArgumentException
|
||||
* @throws InvalidSignException
|
||||
*
|
||||
* @return Support
|
||||
*/
|
||||
public static function create(Config $config)
|
||||
{
|
||||
if (php_sapi_name() === 'cli' || !(self::$instance instanceof self)) {
|
||||
self::$instance = new self($config);
|
||||
|
||||
self::setDevKey();
|
||||
}
|
||||
|
||||
return self::$instance;
|
||||
}
|
||||
|
||||
/**
|
||||
* getInstance.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @throws InvalidArgumentException
|
||||
*
|
||||
* @return Support
|
||||
*/
|
||||
public static function getInstance()
|
||||
{
|
||||
if (is_null(self::$instance)) {
|
||||
throw new InvalidArgumentException('You Should [Create] First Before Using');
|
||||
}
|
||||
|
||||
return self::$instance;
|
||||
}
|
||||
|
||||
/**
|
||||
* clear.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @return void
|
||||
*/
|
||||
public static function clear()
|
||||
{
|
||||
self::$instance = null;
|
||||
}
|
||||
|
||||
/**
|
||||
* Request wechat api.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param string $endpoint
|
||||
* @param array $data
|
||||
* @param bool $cert
|
||||
*
|
||||
* @throws GatewayException
|
||||
* @throws InvalidArgumentException
|
||||
* @throws InvalidSignException
|
||||
*
|
||||
* @return Collection
|
||||
*/
|
||||
public static function requestApi($endpoint, $data, $cert = false): Collection
|
||||
{
|
||||
Events::dispatch(new Events\ApiRequesting('Wechat', '', self::$instance->getBaseUri().$endpoint, $data));
|
||||
|
||||
$result = self::$instance->post(
|
||||
$endpoint,
|
||||
self::toXml($data),
|
||||
$cert ? [
|
||||
'cert' => self::$instance->cert_client,
|
||||
'ssl_key' => self::$instance->cert_key,
|
||||
] : []
|
||||
);
|
||||
$result = is_array($result) ? $result : self::fromXml($result);
|
||||
|
||||
Events::dispatch(new Events\ApiRequested('Wechat', '', self::$instance->getBaseUri().$endpoint, $result));
|
||||
|
||||
return self::processingApiResult($endpoint, $result);
|
||||
}
|
||||
|
||||
/**
|
||||
* Filter payload.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param array $payload
|
||||
* @param array|string $params
|
||||
* @param bool $preserve_notify_url
|
||||
*
|
||||
* @throws InvalidArgumentException
|
||||
*
|
||||
* @return array
|
||||
*/
|
||||
public static function filterPayload($payload, $params, $preserve_notify_url = false): array
|
||||
{
|
||||
$type = self::getTypeName($params['type'] ?? '');
|
||||
|
||||
$payload = array_merge(
|
||||
$payload,
|
||||
is_array($params) ? $params : ['out_trade_no' => $params]
|
||||
);
|
||||
$payload['appid'] = self::$instance->getConfig($type, '');
|
||||
|
||||
if (self::$instance->getConfig('mode', Wechat::MODE_NORMAL) === Wechat::MODE_SERVICE) {
|
||||
$payload['sub_appid'] = self::$instance->getConfig('sub_'.$type, '');
|
||||
}
|
||||
|
||||
unset($payload['trade_type'], $payload['type']);
|
||||
if (!$preserve_notify_url) {
|
||||
unset($payload['notify_url']);
|
||||
}
|
||||
|
||||
$payload['sign'] = self::generateSign($payload);
|
||||
|
||||
return $payload;
|
||||
}
|
||||
|
||||
/**
|
||||
* Generate wechat sign.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param array $data
|
||||
*
|
||||
* @throws InvalidArgumentException
|
||||
*
|
||||
* @return string
|
||||
*/
|
||||
public static function generateSign($data): string
|
||||
{
|
||||
$key = self::$instance->key;
|
||||
|
||||
if (is_null($key)) {
|
||||
throw new InvalidArgumentException('Missing Wechat Config -- [key]');
|
||||
}
|
||||
|
||||
ksort($data);
|
||||
|
||||
$string = md5(self::getSignContent($data).'&key='.$key);
|
||||
|
||||
Log::debug('Wechat Generate Sign Before UPPER', [$data, $string]);
|
||||
|
||||
return strtoupper($string);
|
||||
}
|
||||
|
||||
/**
|
||||
* Generate sign content.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param array $data
|
||||
*
|
||||
* @return string
|
||||
*/
|
||||
public static function getSignContent($data): string
|
||||
{
|
||||
$buff = '';
|
||||
|
||||
foreach ($data as $k => $v) {
|
||||
$buff .= ($k != 'sign' && $v != '' && !is_array($v)) ? $k.'='.$v.'&' : '';
|
||||
}
|
||||
|
||||
Log::debug('Wechat Generate Sign Content Before Trim', [$data, $buff]);
|
||||
|
||||
return trim($buff, '&');
|
||||
}
|
||||
|
||||
/**
|
||||
* Decrypt refund contents.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param string $contents
|
||||
*
|
||||
* @return string
|
||||
*/
|
||||
public static function decryptRefundContents($contents): string
|
||||
{
|
||||
return openssl_decrypt(
|
||||
base64_decode($contents),
|
||||
'AES-256-ECB',
|
||||
md5(self::$instance->key),
|
||||
OPENSSL_RAW_DATA
|
||||
);
|
||||
}
|
||||
|
||||
/**
|
||||
* Convert array to xml.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param array $data
|
||||
*
|
||||
* @throws InvalidArgumentException
|
||||
*
|
||||
* @return string
|
||||
*/
|
||||
public static function toXml($data): string
|
||||
{
|
||||
if (!is_array($data) || count($data) <= 0) {
|
||||
throw new InvalidArgumentException('Convert To Xml Error! Invalid Array!');
|
||||
}
|
||||
|
||||
$xml = '<xml>';
|
||||
foreach ($data as $key => $val) {
|
||||
$xml .= is_numeric($val) ? '<'.$key.'>'.$val.'</'.$key.'>' :
|
||||
'<'.$key.'><![CDATA['.$val.']]></'.$key.'>';
|
||||
}
|
||||
$xml .= '</xml>';
|
||||
|
||||
return $xml;
|
||||
}
|
||||
|
||||
/**
|
||||
* Convert xml to array.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param string $xml
|
||||
*
|
||||
* @throws InvalidArgumentException
|
||||
*
|
||||
* @return array
|
||||
*/
|
||||
public static function fromXml($xml): array
|
||||
{
|
||||
if (!$xml) {
|
||||
throw new InvalidArgumentException('Convert To Array Error! Invalid Xml!');
|
||||
}
|
||||
|
||||
libxml_disable_entity_loader(true);
|
||||
|
||||
return json_decode(json_encode(simplexml_load_string($xml, 'SimpleXMLElement', LIBXML_NOCDATA), JSON_UNESCAPED_UNICODE), true);
|
||||
}
|
||||
|
||||
/**
|
||||
* Get service config.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param null|string $key
|
||||
* @param null|mixed $default
|
||||
*
|
||||
* @return mixed|null
|
||||
*/
|
||||
public function getConfig($key = null, $default = null)
|
||||
{
|
||||
if (is_null($key)) {
|
||||
return $this->config->all();
|
||||
}
|
||||
|
||||
if ($this->config->has($key)) {
|
||||
return $this->config[$key];
|
||||
}
|
||||
|
||||
return $default;
|
||||
}
|
||||
|
||||
/**
|
||||
* Get app id according to param type.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param string $type
|
||||
*
|
||||
* @return string
|
||||
*/
|
||||
public static function getTypeName($type = ''): string
|
||||
{
|
||||
switch ($type) {
|
||||
case '':
|
||||
$type = 'app_id';
|
||||
break;
|
||||
case 'app':
|
||||
$type = 'appid';
|
||||
break;
|
||||
default:
|
||||
$type = $type.'_id';
|
||||
}
|
||||
|
||||
return $type;
|
||||
}
|
||||
|
||||
/**
|
||||
* Get Base Uri.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @return string
|
||||
*/
|
||||
public function getBaseUri()
|
||||
{
|
||||
return $this->baseUri;
|
||||
}
|
||||
|
||||
/**
|
||||
* processingApiResult.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param $endpoint
|
||||
* @param array $result
|
||||
*
|
||||
* @throws GatewayException
|
||||
* @throws InvalidArgumentException
|
||||
* @throws InvalidSignException
|
||||
*
|
||||
* @return Collection
|
||||
*/
|
||||
protected static function processingApiResult($endpoint, array $result)
|
||||
{
|
||||
if (!isset($result['return_code']) || $result['return_code'] != 'SUCCESS') {
|
||||
throw new GatewayException(
|
||||
'Get Wechat API Error:'.($result['return_msg'] ?? $result['retmsg'] ?? ''),
|
||||
$result
|
||||
);
|
||||
}
|
||||
|
||||
if (isset($result['result_code']) && $result['result_code'] != 'SUCCESS') {
|
||||
throw new BusinessException(
|
||||
'Wechat Business Error: '.$result['err_code'].' - '.$result['err_code_des'],
|
||||
$result
|
||||
);
|
||||
}
|
||||
|
||||
if ($endpoint === 'pay/getsignkey' ||
|
||||
strpos($endpoint, 'mmpaymkttransfers') !== false ||
|
||||
self::generateSign($result) === $result['sign']) {
|
||||
return new Collection($result);
|
||||
}
|
||||
|
||||
Events::dispatch(new Events\SignFailed('Wechat', '', $result));
|
||||
|
||||
throw new InvalidSignException('Wechat Sign Verify FAILED', $result);
|
||||
}
|
||||
|
||||
/**
|
||||
* setDevKey.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @throws GatewayException
|
||||
* @throws InvalidArgumentException
|
||||
* @throws InvalidSignException
|
||||
* @throws Exception
|
||||
*
|
||||
* @return Support
|
||||
*/
|
||||
private static function setDevKey()
|
||||
{
|
||||
if (self::$instance->mode == Wechat::MODE_DEV) {
|
||||
$data = [
|
||||
'mch_id' => self::$instance->mch_id,
|
||||
'nonce_str' => Str::random(),
|
||||
];
|
||||
$data['sign'] = self::generateSign($data);
|
||||
|
||||
$result = self::requestApi('pay/getsignkey', $data);
|
||||
|
||||
self::$instance->config->set('key', $result['sandbox_signkey']);
|
||||
}
|
||||
|
||||
return self::$instance;
|
||||
}
|
||||
|
||||
/**
|
||||
* Set Http options.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @return self
|
||||
*/
|
||||
private function setHttpOptions(): self
|
||||
{
|
||||
if ($this->config->has('http') && is_array($this->config->get('http'))) {
|
||||
$this->config->forget('http.base_uri');
|
||||
$this->httpOptions = $this->config->get('http');
|
||||
}
|
||||
|
||||
return $this;
|
||||
}
|
||||
}
|
||||
@ -1,87 +0,0 @@
|
||||
<?php
|
||||
|
||||
namespace Yansongda\Pay\Gateways\Wechat;
|
||||
|
||||
use Symfony\Component\HttpFoundation\Request;
|
||||
use Yansongda\Pay\Events;
|
||||
use Yansongda\Pay\Exceptions\GatewayException;
|
||||
use Yansongda\Pay\Exceptions\InvalidArgumentException;
|
||||
use Yansongda\Pay\Exceptions\InvalidSignException;
|
||||
use Yansongda\Pay\Gateways\Wechat;
|
||||
use Yansongda\Supports\Collection;
|
||||
|
||||
class TransferGateway extends Gateway
|
||||
{
|
||||
/**
|
||||
* Pay an order.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param string $endpoint
|
||||
* @param array $payload
|
||||
*
|
||||
* @throws GatewayException
|
||||
* @throws InvalidArgumentException
|
||||
* @throws InvalidSignException
|
||||
*
|
||||
* @return Collection
|
||||
*/
|
||||
public function pay($endpoint, array $payload): Collection
|
||||
{
|
||||
if ($this->mode === Wechat::MODE_SERVICE) {
|
||||
unset($payload['sub_mch_id'], $payload['sub_appid']);
|
||||
}
|
||||
|
||||
$type = Support::getTypeName($payload['type'] ?? '');
|
||||
|
||||
$payload['mch_appid'] = Support::getInstance()->getConfig($type, '');
|
||||
$payload['mchid'] = $payload['mch_id'];
|
||||
|
||||
if (php_sapi_name() !== 'cli' && !isset($payload['spbill_create_ip'])) {
|
||||
$payload['spbill_create_ip'] = Request::createFromGlobals()->server->get('SERVER_ADDR');
|
||||
}
|
||||
|
||||
unset($payload['appid'], $payload['mch_id'], $payload['trade_type'],
|
||||
$payload['notify_url'], $payload['type']);
|
||||
|
||||
$payload['sign'] = Support::generateSign($payload);
|
||||
|
||||
Events::dispatch(new Events\PayStarted('Wechat', 'Transfer', $endpoint, $payload));
|
||||
|
||||
return Support::requestApi(
|
||||
'mmpaymkttransfers/promotion/transfers',
|
||||
$payload,
|
||||
true
|
||||
);
|
||||
}
|
||||
|
||||
/**
|
||||
* Find.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param $order
|
||||
*
|
||||
* @return array
|
||||
*/
|
||||
public function find($order): array
|
||||
{
|
||||
return [
|
||||
'endpoint' => 'mmpaymkttransfers/gettransferinfo',
|
||||
'order' => is_array($order) ? $order : ['partner_trade_no' => $order],
|
||||
'cert' => true,
|
||||
];
|
||||
}
|
||||
|
||||
/**
|
||||
* Get trade type config.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @return string
|
||||
*/
|
||||
protected function getTradeType(): string
|
||||
{
|
||||
return '';
|
||||
}
|
||||
}
|
||||
@ -1,52 +0,0 @@
|
||||
<?php
|
||||
|
||||
namespace Yansongda\Pay\Gateways\Wechat;
|
||||
|
||||
use Symfony\Component\HttpFoundation\RedirectResponse;
|
||||
use Yansongda\Pay\Events;
|
||||
use Yansongda\Pay\Exceptions\GatewayException;
|
||||
use Yansongda\Pay\Exceptions\InvalidArgumentException;
|
||||
use Yansongda\Pay\Exceptions\InvalidSignException;
|
||||
|
||||
class WapGateway extends Gateway
|
||||
{
|
||||
/**
|
||||
* Pay an order.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param string $endpoint
|
||||
* @param array $payload
|
||||
*
|
||||
* @throws GatewayException
|
||||
* @throws InvalidArgumentException
|
||||
* @throws InvalidSignException
|
||||
*
|
||||
* @return RedirectResponse
|
||||
*/
|
||||
public function pay($endpoint, array $payload): RedirectResponse
|
||||
{
|
||||
$payload['trade_type'] = $this->getTradeType();
|
||||
|
||||
Events::dispatch(new Events\PayStarted('Wechat', 'Wap', $endpoint, $payload));
|
||||
|
||||
$mweb_url = $this->preOrder($payload)->get('mweb_url');
|
||||
|
||||
$url = is_null(Support::getInstance()->return_url) ? $mweb_url : $mweb_url.
|
||||
'&redirect_url='.urlencode(Support::getInstance()->return_url);
|
||||
|
||||
return RedirectResponse::create($url);
|
||||
}
|
||||
|
||||
/**
|
||||
* Get trade type config.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @return string
|
||||
*/
|
||||
protected function getTradeType(): string
|
||||
{
|
||||
return 'MWEB';
|
||||
}
|
||||
}
|
||||
@ -1,142 +0,0 @@
|
||||
<?php
|
||||
|
||||
namespace Yansongda\Pay\Listeners;
|
||||
|
||||
use Symfony\Component\EventDispatcher\EventSubscriberInterface;
|
||||
use Yansongda\Pay\Events;
|
||||
use Yansongda\Pay\Log;
|
||||
|
||||
class KernelLogSubscriber implements EventSubscriberInterface
|
||||
{
|
||||
/**
|
||||
* Returns an array of event names this subscriber wants to listen to.
|
||||
*
|
||||
* The array keys are event names and the value can be:
|
||||
*
|
||||
* * The method name to call (priority defaults to 0)
|
||||
* * An array composed of the method name to call and the priority
|
||||
* * An array of arrays composed of the method names to call and respective
|
||||
* priorities, or 0 if unset
|
||||
*
|
||||
* For instance:
|
||||
*
|
||||
* * array('eventName' => 'methodName')
|
||||
* * array('eventName' => array('methodName', $priority))
|
||||
* * array('eventName' => array(array('methodName1', $priority), array('methodName2')))
|
||||
*
|
||||
* @return array The event names to listen to
|
||||
*/
|
||||
public static function getSubscribedEvents()
|
||||
{
|
||||
return [
|
||||
Events\PayStarting::class => ['writePayStartingLog', 256],
|
||||
Events\PayStarted::class => ['writePayStartedLog', 256],
|
||||
Events\ApiRequesting::class => ['writeApiRequestingLog', 256],
|
||||
Events\ApiRequested::class => ['writeApiRequestedLog', 256],
|
||||
Events\SignFailed::class => ['writeSignFailedLog', 256],
|
||||
Events\RequestReceived::class => ['writeRequestReceivedLog', 256],
|
||||
Events\MethodCalled::class => ['writeMethodCalledLog', 256],
|
||||
];
|
||||
}
|
||||
|
||||
/**
|
||||
* writePayStartingLog.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param Events\PayStarting $event
|
||||
*
|
||||
* @return void
|
||||
*/
|
||||
public function writePayStartingLog(Events\PayStarting $event)
|
||||
{
|
||||
Log::debug("Starting To {$event->driver}", [$event->gateway, $event->params]);
|
||||
}
|
||||
|
||||
/**
|
||||
* writePayStartedLog.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param Events\PayStarted $event
|
||||
*
|
||||
* @return void
|
||||
*/
|
||||
public function writePayStartedLog(Events\PayStarted $event)
|
||||
{
|
||||
Log::info(
|
||||
"{$event->driver} {$event->gateway} Has Started",
|
||||
[$event->endpoint, $event->payload]
|
||||
);
|
||||
}
|
||||
|
||||
/**
|
||||
* writeApiRequestingLog.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param Events\ApiRequesting $event
|
||||
*
|
||||
* @return void
|
||||
*/
|
||||
public function writeApiRequestingLog(Events\ApiRequesting $event)
|
||||
{
|
||||
Log::debug("Requesting To {$event->driver} Api", [$event->endpoint, $event->payload]);
|
||||
}
|
||||
|
||||
/**
|
||||
* writeApiRequestedLog.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param Events\ApiRequested $event
|
||||
*
|
||||
* @return void
|
||||
*/
|
||||
public function writeApiRequestedLog(Events\ApiRequested $event)
|
||||
{
|
||||
Log::debug("Result Of {$event->driver} Api", $event->result);
|
||||
}
|
||||
|
||||
/**
|
||||
* writeSignFailedLog.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param Events\SignFailed $event
|
||||
*
|
||||
* @return void
|
||||
*/
|
||||
public function writeSignFailedLog(Events\SignFailed $event)
|
||||
{
|
||||
Log::warning("{$event->driver} Sign Verify FAILED", $event->data);
|
||||
}
|
||||
|
||||
/**
|
||||
* writeRequestReceivedLog.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param Events\RequestReceived $event
|
||||
*
|
||||
* @return void
|
||||
*/
|
||||
public function writeRequestReceivedLog(Events\RequestReceived $event)
|
||||
{
|
||||
Log::info("Received {$event->driver} Request", $event->data);
|
||||
}
|
||||
|
||||
/**
|
||||
* writeMethodCalledLog.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param Events\MethodCalled $event
|
||||
*
|
||||
* @return void
|
||||
*/
|
||||
public function writeMethodCalledLog(Events\MethodCalled $event)
|
||||
{
|
||||
Log::info("{$event->driver} {$event->gateway} Method Has Called", [$event->endpoint, $event->payload]);
|
||||
}
|
||||
}
|
||||
49
src/Log.php
49
src/Log.php
@ -1,49 +0,0 @@
|
||||
<?php
|
||||
|
||||
namespace Yansongda\Pay;
|
||||
|
||||
use Yansongda\Supports\Log as BaseLog;
|
||||
|
||||
/**
|
||||
* @method static void emergency($message, array $context = array())
|
||||
* @method static void alert($message, array $context = array())
|
||||
* @method static void critical($message, array $context = array())
|
||||
* @method static void error($message, array $context = array())
|
||||
* @method static void warning($message, array $context = array())
|
||||
* @method static void notice($message, array $context = array())
|
||||
* @method static void info($message, array $context = array())
|
||||
* @method static void debug($message, array $context = array())
|
||||
* @method static void log($message, array $context = array())
|
||||
*/
|
||||
class Log
|
||||
{
|
||||
/**
|
||||
* Forward call.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param string $method
|
||||
* @param array $args
|
||||
*
|
||||
* @return mixed
|
||||
*/
|
||||
public static function __callStatic($method, $args)
|
||||
{
|
||||
return forward_static_call_array([BaseLog::class, $method], $args);
|
||||
}
|
||||
|
||||
/**
|
||||
* Forward call.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param string $method
|
||||
* @param array $args
|
||||
*
|
||||
* @return mixed
|
||||
*/
|
||||
public function __call($method, $args)
|
||||
{
|
||||
return call_user_func_array([BaseLog::class, $method], $args);
|
||||
}
|
||||
}
|
||||
145
src/Pay.php
145
src/Pay.php
@ -2,141 +2,34 @@
|
||||
|
||||
namespace Yansongda\Pay;
|
||||
|
||||
use Exception;
|
||||
use Yansongda\Pay\Contracts\GatewayApplicationInterface;
|
||||
use Yansongda\Pay\Exceptions\InvalidGatewayException;
|
||||
use Yansongda\Pay\Gateways\Alipay;
|
||||
use Yansongda\Pay\Gateways\Wechat;
|
||||
use Yansongda\Pay\Listeners\KernelLogSubscriber;
|
||||
use Yansongda\Supports\Config;
|
||||
use Yansongda\Supports\Log;
|
||||
use Yansongda\Supports\Str;
|
||||
use Pimple\Container;
|
||||
use Yansongda\Pay\Service\ConfigService;
|
||||
use Yansongda\Pay\Service\EventService;
|
||||
use Yansongda\Pay\Service\LoggerService;
|
||||
|
||||
/**
|
||||
* @method static Alipay alipay(array $config) 支付宝
|
||||
* @method static Wechat wechat(array $config) 微信
|
||||
*/
|
||||
class Pay
|
||||
class Pay extends Container
|
||||
{
|
||||
/**
|
||||
* Config.
|
||||
* service.
|
||||
*
|
||||
* @var Config
|
||||
* @var array
|
||||
*/
|
||||
protected $config;
|
||||
protected $baseService = [
|
||||
ConfigService::class,
|
||||
LoggerService::class,
|
||||
EventService::class,
|
||||
];
|
||||
|
||||
/**
|
||||
* Bootstrap.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param array $config
|
||||
*
|
||||
* @throws Exception
|
||||
*/
|
||||
public function __construct(array $config)
|
||||
public static function __callStatic($method, $params)
|
||||
{
|
||||
$this->config = new Config($config);
|
||||
|
||||
$this->registerLogService();
|
||||
$this->registerEventService();
|
||||
$app = new static();
|
||||
|
||||
$app->create();
|
||||
}
|
||||
|
||||
/**
|
||||
* Magic static call.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param string $method
|
||||
* @param array $params
|
||||
*
|
||||
* @throws InvalidGatewayException
|
||||
* @throws Exception
|
||||
*
|
||||
* @return GatewayApplicationInterface
|
||||
*/
|
||||
public static function __callStatic($method, $params): GatewayApplicationInterface
|
||||
protected function create()
|
||||
{
|
||||
$app = new self(...$params);
|
||||
|
||||
return $app->create($method);
|
||||
|
||||
}
|
||||
|
||||
/**
|
||||
* Create a instance.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @param string $method
|
||||
*
|
||||
* @throws InvalidGatewayException
|
||||
*
|
||||
* @return GatewayApplicationInterface
|
||||
*/
|
||||
protected function create($method): GatewayApplicationInterface
|
||||
{
|
||||
$gateway = __NAMESPACE__.'\\Gateways\\'.Str::studly($method);
|
||||
|
||||
if (class_exists($gateway)) {
|
||||
return self::make($gateway);
|
||||
}
|
||||
|
||||
throw new InvalidGatewayException("Gateway [{$method}] Not Exists");
|
||||
}
|
||||
|
||||
/**
|
||||
* Make a gateway.
|
||||
*
|
||||
* @author yansongda <me@yansonga.cn>
|
||||
*
|
||||
* @param string $gateway
|
||||
*
|
||||
* @throws InvalidGatewayException
|
||||
*
|
||||
* @return GatewayApplicationInterface
|
||||
*/
|
||||
protected function make($gateway): GatewayApplicationInterface
|
||||
{
|
||||
$app = new $gateway($this->config);
|
||||
|
||||
if ($app instanceof GatewayApplicationInterface) {
|
||||
return $app;
|
||||
}
|
||||
|
||||
throw new InvalidGatewayException("Gateway [{$gateway}] Must Be An Instance Of GatewayApplicationInterface");
|
||||
}
|
||||
|
||||
/**
|
||||
* Register log service.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @throws Exception
|
||||
*/
|
||||
protected function registerLogService()
|
||||
{
|
||||
$logger = Log::createLogger(
|
||||
$this->config->get('log.file'),
|
||||
'yansongda.pay',
|
||||
$this->config->get('log.level', 'warning'),
|
||||
$this->config->get('log.type', 'daily'),
|
||||
$this->config->get('log.max_file', 30)
|
||||
);
|
||||
|
||||
Log::setLogger($logger);
|
||||
}
|
||||
|
||||
/**
|
||||
* Register event service.
|
||||
*
|
||||
* @author yansongda <me@yansongda.cn>
|
||||
*
|
||||
* @return void
|
||||
*/
|
||||
protected function registerEventService()
|
||||
{
|
||||
Events::setDispatcher(Events::createDispatcher());
|
||||
|
||||
Events::addSubscriber(new KernelLogSubscriber());
|
||||
}
|
||||
}
|
||||
}
|
||||
8
src/Service/Alipay/AlipayService.php
Normal file
8
src/Service/Alipay/AlipayService.php
Normal file
@ -0,0 +1,8 @@
|
||||
<?php
|
||||
|
||||
namespace Yansongda\Pay\Service\Alipay;
|
||||
|
||||
class AlipayService
|
||||
{
|
||||
|
||||
}
|
||||
22
src/Service/ConfigService.php
Normal file
22
src/Service/ConfigService.php
Normal file
@ -0,0 +1,22 @@
|
||||
<?php
|
||||
|
||||
namespace Yansongda\Pay\Service;
|
||||
|
||||
use Pimple\Container;
|
||||
use Yansongda\Pay\Contract\ServiceInterface;
|
||||
|
||||
class ConfigService implements ServiceInterface
|
||||
{
|
||||
/**
|
||||
* Registers services on the given container.
|
||||
*
|
||||
* This method should only be used to configure services and parameters.
|
||||
* It should not get services.
|
||||
*
|
||||
* @param Container $pimple A container instance
|
||||
*/
|
||||
public function register (Container $pimple)
|
||||
{
|
||||
|
||||
}
|
||||
}
|
||||
8
src/Service/EventService.php
Normal file
8
src/Service/EventService.php
Normal file
@ -0,0 +1,8 @@
|
||||
<?php
|
||||
|
||||
namespace Yansongda\Pay\Service;
|
||||
|
||||
class EventService
|
||||
{
|
||||
|
||||
}
|
||||
22
src/Service/LoggerService.php
Normal file
22
src/Service/LoggerService.php
Normal file
@ -0,0 +1,22 @@
|
||||
<?php
|
||||
|
||||
namespace Yansongda\Pay\Service;
|
||||
|
||||
use Pimple\Container;
|
||||
use Yansongda\Pay\Contract\ServiceInterface;
|
||||
|
||||
class LoggerService implements ServiceInterface
|
||||
{
|
||||
/**
|
||||
* Registers services on the given container.
|
||||
*
|
||||
* This method should only be used to configure services and parameters.
|
||||
* It should not get services.
|
||||
*
|
||||
* @param Container $pimple A container instance
|
||||
*/
|
||||
public function register(Container $pimple)
|
||||
{
|
||||
|
||||
}
|
||||
}
|
||||
8
src/Service/Wechat/WechatService.php
Normal file
8
src/Service/Wechat/WechatService.php
Normal file
@ -0,0 +1,8 @@
|
||||
<?php
|
||||
|
||||
namespace Yansongda\Pay\Service\Wechat;
|
||||
|
||||
class WechatService
|
||||
{
|
||||
|
||||
}
|
||||
@ -1,16 +0,0 @@
|
||||
<?php
|
||||
|
||||
namespace Yansongda\Pay\Tests;
|
||||
|
||||
use PHPUnit\Framework\TestCase as PHPUnitTestCase;
|
||||
|
||||
class TestCase extends PHPUnitTestCase
|
||||
{
|
||||
public function setUp()
|
||||
{
|
||||
}
|
||||
|
||||
public function tearDown()
|
||||
{
|
||||
}
|
||||
}
|
||||
Loading…
Reference in New Issue
Block a user