QueryUseFlowPlugin::assembly()   A
last analyzed

Complexity

Conditions 2
Paths 2

Size

Total Lines 19
Code Lines 10

Duplication

Lines 0
Ratio 0 %

Importance

Changes 0
Metric Value
cc 2
eloc 10
nc 2
nop 2
dl 0
loc 19
rs 9.9332
c 0
b 0
f 0
1
<?php
2
3
declare(strict_types=1);
4
5
namespace Yansongda\Pay\Plugin\Wechat\V3\Marketing\Coupon\Stock;
6
7
use Closure;
8
use Yansongda\Artful\Contract\PluginInterface;
9
use Yansongda\Artful\Exception\InvalidParamsException;
10
use Yansongda\Artful\Logger;
11
use Yansongda\Artful\Rocket;
12
use Yansongda\Pay\Exception\Exception;
13
14
/**
15
 * @see https://pay.weixin.qq.com/docs/merchant/apis/cash-coupons/stock/use-flow.html
16
 * @see https://pay.weixin.qq.com/docs/partner/apis/cash-coupons/stock/use-flow.html
17
 */
18
class QueryUseFlowPlugin implements PluginInterface
19
{
20
    /**
21
     * @throws InvalidParamsException
22
     */
23
    public function assembly(Rocket $rocket, Closure $next): Rocket
24
    {
25
        Logger::debug('[Wechat][V3][Marketing][Coupon][Stock][QueryUseFlowPlugin] 插件开始装载', ['rocket' => $rocket]);
26
27
        $stockId = $rocket->getPayload()?->get('stock_id') ?? null;
28
29
        if (empty($stockId)) {
30
            throw new InvalidParamsException(Exception::PARAMS_NECESSARY_PARAMS_MISSING, '参数异常: 下载批次核销明细,参数缺少 `stock_id`');
31
        }
32
33
        $rocket->setPayload([
34
            '_method' => 'GET',
35
            '_url' => 'v3/marketing/favor/stocks/'.$stockId.'/use-flow',
36
            '_service_url' => 'v3/marketing/favor/stocks/'.$stockId.'/use-flow',
37
        ]);
38
39
        Logger::info('[Wechat][V3][Marketing][Coupon][Stock][QueryUseFlowPlugin] 插件装载完毕', ['rocket' => $rocket]);
40
41
        return $next($rocket);
42
    }
43
}
44