public function handle()
{
$server = new Server("tcp://0.0.0.0:1111");
$server->addMethod('test', $this);
$server->start();
}
public function test($token, $param)
{
return (new RpcUserService())->test($token, $param);
}
public function test($token, array $param)
{
if (!JWTAuth::setToken($token)->check()) {
return ['code' => 401, 'msg' => __('messages.登录过期'), 'data' => []];
}
if (!isset($param['currency_code'])) {
return ['code' => 402, 'msg' => __('messages.参数错误'), 'data' => []];
}
$user = JWTAuth::setToken($token)->authenticate();
$user = (new UserBalance())
->where(['id' => $user->id])
->where(['code' => $param['code']])
->select('balance')
->first();
return ['code' => 200, 'msg' => __('messages.成功'), 'data' => $user];
}