mirror of
http://124.126.16.154:8888/singularity/HyperfDevelopmentKitCore.git
synced 2026-01-15 07:15:06 +08:00
111 lines
4.3 KiB
PHP
111 lines
4.3 KiB
PHP
<?php
|
|
|
|
/**
|
|
* ClassicCoreMiddleware.php@hyperf-development-kit
|
|
*
|
|
* @author 李东云<dongyun.li@luxcreo.cn>
|
|
* Powered by PhpStorm
|
|
* Created on 2022/4/29
|
|
*/
|
|
|
|
namespace Singularity\HDK\Core\Middleware;
|
|
|
|
use Hyperf\Contract\Arrayable;
|
|
use Hyperf\Contract\Jsonable;
|
|
use Hyperf\Contract\LengthAwarePaginatorInterface;
|
|
use Hyperf\Di\Annotation\Inject;
|
|
use Hyperf\HttpMessage\Stream\SwooleStream;
|
|
use Hyperf\HttpServer\CoreMiddleware;
|
|
use Hyperf\Utils\Codec\Json;
|
|
use Lmc\HttpConstants\Header;
|
|
use Psr\Http\Message\ResponseInterface;
|
|
use Psr\Http\Message\ServerRequestInterface;
|
|
use Singularity\HDK\Core\Service\UtilsService;
|
|
|
|
/**
|
|
* Singularity\HDK\Utils\Middleware\ClassicCoreMiddleware@hyperf-development-kit
|
|
*
|
|
* @author 李东云<dongyun.li@luxcreo.cn>
|
|
* Powered by PhpStorm
|
|
* Created on 2022/4/29
|
|
*
|
|
* @deprecated
|
|
* @see CommonCoreMiddleware
|
|
*/
|
|
class ClassicCoreMiddleware extends CoreMiddleware
|
|
{
|
|
#[Inject]
|
|
private UtilsService $utilsService;
|
|
|
|
/**
|
|
* Transfer the non-standard response content to a standard response object.
|
|
* @template TKey of array-key
|
|
* @template TValue
|
|
* @param null|array<TKey, TValue>|Arrayable<TKey, TValue>|Jsonable|string $response
|
|
*/
|
|
protected function transferToResponse($response, ServerRequestInterface $request): ResponseInterface
|
|
{
|
|
$code_name = config('common.response.code_name');
|
|
$message_name = config('common.response.message_name');
|
|
$data_name = config('common.response.data_name');
|
|
// 分页数据
|
|
if ($response instanceof LengthAwarePaginatorInterface) {
|
|
$paginator = $response;
|
|
$fact_response = $this->response()->withHeader('Per-Page', (string)$paginator->perPage())->withHeader(
|
|
'Total',
|
|
(string)$paginator->total()
|
|
)->withHeader('Current-Page', (string)$paginator->currentPage())->withHeader(
|
|
'Total-Pages',
|
|
(string)$paginator->hasPages()
|
|
);
|
|
$fact_response = $this->utilsService->extendLinkToHeader($fact_response, $paginator->nextPageUrl(), 'next');
|
|
$fact_response = $this->utilsService->extendLinkToHeader(
|
|
$fact_response,
|
|
$paginator->url($paginator->lastPage()),
|
|
'last'
|
|
);
|
|
$fact_response = $this->utilsService->extendLinkToHeader($fact_response, $paginator->url(1), 'first');
|
|
$fact_response = $this->utilsService->extendLinkToHeader(
|
|
$fact_response,
|
|
$paginator->previousPageUrl(),
|
|
'prev'
|
|
);
|
|
return $fact_response->withAddedHeader(Header::CONTENT_TYPE, 'application/json')->withBody(
|
|
new SwooleStream(
|
|
Json::encode(
|
|
[
|
|
$code_name => 200,
|
|
$message_name => 'ok',
|
|
$data_name => $response->items(),
|
|
'meta' => [
|
|
'currentPage' => $paginator->currentPage(),
|
|
'lastPage' => $paginator->lastPage(),
|
|
'perPage' => $paginator->perPage(),
|
|
'total' => $paginator->total(),
|
|
],
|
|
]
|
|
)
|
|
)
|
|
);
|
|
}
|
|
// 普通数组
|
|
if (is_array($response) || $response instanceof Arrayable) {
|
|
$response = [$code_name => 200, $message_name => 'ok', $data_name => $response];
|
|
return $this->response()->withAddedHeader(Header::CONTENT_TYPE, 'application/json')->withBody(
|
|
new SwooleStream(Json::encode($response))
|
|
);
|
|
}
|
|
// 可 Json 化的数据结构
|
|
if ($response instanceof Jsonable) {
|
|
$response = [$code_name => 200, $message_name => 'ok', $data_name => Json::decode((string)$response)];
|
|
return $this->response()->withAddedHeader(Header::CONTENT_TYPE, 'application/json')->withBody(
|
|
new SwooleStream(Json::encode($response))
|
|
);
|
|
}
|
|
// 其他默认按字符串处理
|
|
return $this->response()->withAddedHeader(Header::CONTENT_TYPE, 'text/plain')->withBody(
|
|
new SwooleStream((string)$response)
|
|
);
|
|
}
|
|
}
|