\Yurun\PaySDK\Weixin\NotifyBase

<?php

namespace Yurun\PaySDK\Weixin\Notify;

use Yurun\PaySDK\Lib\XML;
use Yurun\PaySDK\NotifyBase;
use Yurun\PaySDK\Weixin\Reply\Base as ReplyBase;
use Yurun\Util\YurunHttp\Stream\MemoryStream;

/**
 * 微信支付-通知处理基类.
 */
abstract class Base extends NotifyBase
{
    public function __construct()
    {
        parent::__construct();
        $this->replyData = new ReplyBase();
    }

    /**
     * 返回数据.
     *
     * @param bool   $success
     * @param string $message
     *
     * @return void
     */
    public function reply($success, $message = '')
    {
        $this->replyData->return_code = $success ? 'SUCCESS' : 'FAIL';
        $this->replyData->return_msg = $message;
        if (null === $this->swooleResponse)
        {
            echo $this->replyData;
        }
        elseif ($this->swooleResponse instanceof \Swoole\Http\Response)
        {
            $this->swooleResponse->end($this->replyData->toString());
        }
        elseif ($this->swooleResponse instanceof \Psr\Http\Message\ResponseInterface)
        {
            $this->swooleResponse = $this->swooleResponse->withBody(new MemoryStream($this->replyData->toString()));
        }
    }

    /**
     * 获取通知数据.
     *
     * @return array|mixed
     */
    public function getNotifyData()
    {
        if ($this->swooleRequest instanceof \Swoole\Http\Request)
        {
            return XML::fromString($this->swooleRequest->rawContent());
        }
        if ($this->swooleRequest instanceof \Psr\Http\Message\ServerRequestInterface)
        {
            return XML::fromString((string) $this->swooleRequest->getBody());
        }

        return XML::fromString(file_get_contents('php://input'));
    }

    /**
     * 对通知进行验证，是否是正确的通知.
     *
     * @return bool
     */
    public function notifyVerify()
    {
        return $this->sdk->verifyCallback($this->data);
    }
}