Kaylyu\Alipay\F2fpay\Notify\Handler

Complexity

Total Complexity

13

Size/Duplication

Total Lines	137
Duplicated Lines	0 %

Coupling/Cohesion

Components	2
Dependencies	1

Test Coverage

Coverage

0%

Importance

Changes

0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
	handle()	0	1	?
A	fail()	0	4	1
A	toResponse()	0	4	2
A	getMessage()	0	19	4
A	validate()	0	4	1
A	strict()	0	6	3
A	getInput()	0	7	1

<?php

namespace Kaylyu\Alipay\F2fpay\Notify;

use Closure;
use Kaylyu\Alipay\Kernel\Exceptions\Exception;

abstract class Handler
{
    const SUCCESS = 'success';
    const FAILED = 'failed';

    /**
     * @var
     * @author kaylv <kaylv@dayuw.com>
     */
    protected $app;

    /**
     * @var array
     */
    protected $message;

    /**
     * @var string|null
     */
    protected $fail;

    /**
     * @var array
     */
    protected $attributes = [];

    /**
     * Check sign.
     * If failed, throws an exception.
     *
     * @var bool
     */
    protected $check = true;

    /**
     * Respond with sign.
     *
     * @var bool
     */
    protected $sign = true;

    /**
     * Handler constructor.
     * @param $app
     */
    public function __construct($app)
    {
        $this->app = $app;
    }

    /**
     * 处理验签入口
     * @param Closure $closure
     * @author kaylv <kaylv@dayuw.com>
     * @return string
     */
    abstract public function handle(Closure $closure);

    /**
     * @param string $message
     */
    public function fail(string $message)
    {
        $this->fail = $message;
    }

    /**
     * 响应数据
     * @author kaylv <kaylv@dayuw.com>
     * @return string
     */
    public function toResponse()
    {
        return is_null($this->fail) ? self::SUCCESS : self::FAILED;
    }

    /**
     * 获取参数并验签
     * @author kaylv <kaylv@dayuw.com>
     * @return array
     * @throws Exception
     */
    public function getMessage(): array
    {
        if (!empty($this->message)) {
            return $this->message;
        }

        //获取参数
        $message = $this->getInput();

        if (empty($message)) {
            throw new Exception('Invalid Request.', 400);
        }

        if ($this->check) {
            $this->validate($message);
        }

        return $this->message = $message;
    }

    /**
     * 验签
     * @param $message
     * @author kaylv <kaylv@dayuw.com>
     * @throws Exception
     */
    protected function validate($message)
    {
        throw new Exception('Invalid AopClient.', 400);
    }

    /**
     * 处理入口
     * @param mixed $result
     */
    protected function strict($result)
    {
        if (true !== $result && is_null($this->fail)) {
            $this->fail(strval($result));
        }
    }

    /**
     * 获取参数
     * @author kaylv <kaylv@dayuw.com>
     * @return array
     */
    protected function getInput()
    {
        //获取请求参数
        $content = $this->app['request']->all();

        return $content;
    }
}