Passed
Push — master ( ab7eb6...522f6c )
by Songda
03:48 queued 01:30
created

CancelPlugin   A

Complexity

Total Complexity 3

Size/Duplication

Total Lines 31
Duplicated Lines 0 %

Importance

Changes 1
Bugs 0 Features 0
Metric Value
eloc 14
c 1
b 0
f 0
dl 0
loc 31
rs 10
wmc 3

1 Method

Rating   Name   Duplication   Size   Complexity  
A assembly() 0 24 3
1
<?php
2
3
declare(strict_types=1);
4
5
namespace Yansongda\Pay\Plugin\Wechat\V3\Marketing\MchTransfer;
6
7
use Closure;
8
use Yansongda\Artful\Contract\PluginInterface;
9
use Yansongda\Artful\Exception\ContainerException;
10
use Yansongda\Artful\Exception\InvalidParamsException;
11
use Yansongda\Artful\Exception\ServiceNotFoundException;
12
use Yansongda\Artful\Logger;
13
use Yansongda\Artful\Rocket;
14
use Yansongda\Pay\Exception\Exception;
15
use Yansongda\Pay\Pay;
16
17
use function Yansongda\Pay\get_provider_config;
18
19
/**
20
 * @see https://pay.weixin.qq.com/doc/v3/merchant/4012716458
21
 */
22
class CancelPlugin implements PluginInterface
23
{
24
    /**
25
     * @throws InvalidParamsException
26
     * @throws ContainerException
27
     * @throws ServiceNotFoundException
28
     */
29
    public function assembly(Rocket $rocket, Closure $next): Rocket
30
    {
31
        Logger::debug('[Wechat][Marketing][MchTransfer][CancelPlugin] 插件开始装载', ['rocket' => $rocket]);
32
33
        $config = get_provider_config('wechat', $rocket->getParams());
34
        $payload = $rocket->getPayload();
35
        $outBillNo = $payload?->get('out_bill_no') ?? null;
36
37
        if (Pay::MODE_SERVICE === ($config['mode'] ?? Pay::MODE_NORMAL)) {
38
            throw new InvalidParamsException(Exception::PARAMS_PLUGIN_ONLY_SUPPORT_NORMAL_MODE, '参数异常: 撤销转账,只支持普通商户模式,当前配置为服务商模式');
39
        }
40
41
        if (empty($outBillNo)) {
42
            throw new InvalidParamsException(Exception::PARAMS_NECESSARY_PARAMS_MISSING, '参数异常: 撤销转账,参数缺少 `out_bill_no`');
43
        }
44
45
        $rocket->setPayload([
46
            '_method' => 'POST',
47
            '_url' => 'v3/fund-app/mch-transfer/transfer-bills/out-bill-no/'.$outBillNo.'/cancel',
48
        ]);
49
50
        Logger::info('[Wechat][Marketing][MchTransfer][CancelPlugin] 插件装载完毕', ['rocket' => $rocket]);
51
52
        return $next($rocket);
53
    }
54
}
55