Passed
Pull Request — master (#1002)
by
unknown
02:09
created

PayPlugin::assembly()   A

Complexity

Conditions 2
Paths 2

Size

Total Lines 20
Code Lines 11

Duplication

Lines 0
Ratio 0 %

Importance

Changes 0
Metric Value
cc 2
eloc 11
nc 2
nop 2
dl 0
loc 20
rs 9.9
c 0
b 0
f 0
1
<?php
2
3
declare(strict_types=1);
4
5
namespace Yansongda\Pay\Plugin\Jsb\Pay\Scan;
6
7
use Closure;
8
use Yansongda\Artful\Contract\PluginInterface;
9
use Yansongda\Artful\Exception\ContainerException;
10
use Yansongda\Artful\Exception\InvalidConfigException;
11
use Yansongda\Artful\Exception\ServiceNotFoundException;
12
use Yansongda\Artful\Logger;
13
use Yansongda\Artful\Rocket;
14
use Yansongda\Pay\Exception\Exception;
15
16
use function Yansongda\Pay\get_provider_config;
17
18
class PayPlugin implements PluginInterface
19
{
20
    /**
21
     * @throws InvalidConfigException
22
     * @throws ServiceNotFoundException
23
     * @throws ContainerException
24
     */
25
    public function assembly(Rocket $rocket, Closure $next): Rocket
26
    {
27
        Logger::debug('[Jsb][Pay][Scan][PayPlugin] 插件开始装载', ['rocket' => $rocket]);
28
29
        $params = $rocket->getParams();
30
        $config = get_provider_config('jsb', $params);
31
        $backUrl = $rocket->getPayload()['notify_url'] ?? $config['notify_url'] ?? null;
32
33
        if (!$backUrl) {
34
            throw new InvalidConfigException(Exception::CONFIG_JSB_INVALID, '配置异常: 缺少配置参数 -- [notify_url]');
35
        }
36
37
        $rocket->mergePayload([
38
            'service' => 'atPay',
39
            'backUrl' => $backUrl,
40
        ]);
41
42
        Logger::info('[Jsb][Pay][Scan][PayPlugin] 插件装载完毕', ['rocket' => $rocket]);
43
44
        return $next($rocket);
45
    }
46
}
47