mirror of
https://gitee.com/zoujingli/ThinkAdmin.git
synced 2025-09-12 06:59:46 +08:00
115 lines
4.6 KiB
PHP
115 lines
4.6 KiB
PHP
<?php
|
||
|
||
// +----------------------------------------------------------------------
|
||
// | Library for ThinkAdmin
|
||
// +----------------------------------------------------------------------
|
||
// | 版权所有 2014~2021 广州楚才信息科技有限公司 [ http://www.cuci.cc ]
|
||
// +----------------------------------------------------------------------
|
||
// | 官方网站: https://gitee.com/zoujingli/ThinkLibrary
|
||
// +----------------------------------------------------------------------
|
||
// | 开源协议 ( https://mit-license.org )
|
||
// +----------------------------------------------------------------------
|
||
// | gitee 仓库地址 ：https://gitee.com/zoujingli/ThinkLibrary
|
||
// | github 仓库地址 ：https://github.com/zoujingli/ThinkLibrary
|
||
// +----------------------------------------------------------------------
|
||
|
||
declare (strict_types=1);
|
||
|
||
namespace think\admin\extend;
|
||
|
||
use think\App;
|
||
use think\Container;
|
||
use think\exception\HttpResponseException;
|
||
|
||
/**
|
||
* JsonRpc 服务端
|
||
* Class JsonRpcServer
|
||
* @package think\admin\extend
|
||
*/
|
||
class JsonRpcServer
|
||
{
|
||
/**
|
||
* 当前App对象
|
||
* @var App
|
||
*/
|
||
protected $app;
|
||
|
||
/**
|
||
* JsonRpcServer constructor.
|
||
* @param App $app
|
||
*/
|
||
public function __construct(App $app)
|
||
{
|
||
$this->app = $app;
|
||
}
|
||
|
||
/**
|
||
* 静态实例对象
|
||
* @param array $args
|
||
* @return static
|
||
*/
|
||
public static function instance(...$args): JsonRpcServer
|
||
{
|
||
return Container::getInstance()->make(static::class, $args);
|
||
}
|
||
|
||
/**
|
||
* 设置监听对象
|
||
* @param mixed $object
|
||
*/
|
||
public function handle($object)
|
||
{
|
||
// Checks if a JSON-RCP request has been received
|
||
if ($this->app->request->method() !== "POST" || $this->app->request->contentType() !== 'application/json') {
|
||
$this->printMethod($object);
|
||
} else {
|
||
// Reads the input data
|
||
$request = json_decode(file_get_contents('php://input'), true);
|
||
if (empty($request)) {
|
||
$error = ['code' => '-32700', 'message' => '语法解析错误', 'meaning' => '服务端接收到无效的JSON'];
|
||
$response = ['jsonrpc' => '2.0', 'id' => $request['id'], 'result' => null, 'error' => $error];
|
||
} elseif (!isset($request['id']) || !isset($request['method']) || !isset($request['params'])) {
|
||
$error = ['code' => '-32600', 'message' => '无效的请求', 'meaning' => '发送的JSON不是一个有效的请求对象'];
|
||
$response = ['jsonrpc' => '2.0', 'id' => $request['id'], 'result' => null, 'error' => $error];
|
||
} else try {
|
||
// Executes the task on local object
|
||
if (method_exists($object, $request['method'])) {
|
||
$result = call_user_func_array([$object, $request['method']], $request['params']);
|
||
$response = ['jsonrpc' => '2.0', 'id' => $request['id'], 'result' => $result, 'error' => null];
|
||
} else {
|
||
$error = ['code' => '-32601', 'message' => '找不到方法', 'meaning' => '该方法不存在或无效'];
|
||
$response = ['jsonrpc' => '2.0', 'id' => $request['id'], 'result' => null, 'error' => $error];
|
||
}
|
||
} catch (\Exception $exception) {
|
||
$error = ['code' => $exception->getCode(), 'message' => $exception->getMessage()];
|
||
$response = ['jsonrpc' => '2.0', 'id' => $request['id'], 'result' => null, 'error' => $error];
|
||
}
|
||
// Output the response
|
||
throw new HttpResponseException(json($response)->contentType('text/javascript'));
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 打印输出对象方法
|
||
* @param mixed $object
|
||
*/
|
||
protected function printMethod($object)
|
||
{
|
||
try {
|
||
$object = new \ReflectionClass($object);
|
||
echo "<h2>" . $object->getName() . "</h2><hr>";
|
||
foreach ($object->getMethods(\ReflectionMethod::IS_PUBLIC) as $method) {
|
||
$params = [];
|
||
foreach ($method->getParameters() as $parameter) {
|
||
$type = $parameter->getType();
|
||
$params[] = ($type ? "{$type} $" : '$') . $parameter->getName();
|
||
}
|
||
$params = count($params) > 0 ? join(', ', $params) : '';
|
||
echo '<div style="color:#666">' . nl2br($method->getDocComment() ?: '') . '</div>';
|
||
echo "<div style='color:#00E'>{$object->getShortName()}::{$method->getName()}({$params})</div><br>";
|
||
}
|
||
} catch (\Exception $exception) {
|
||
echo "<h3>[{$exception->getCode()}] {$exception->getMessage()}</h3>";
|
||
}
|
||
}
|
||
} |