Compare commits
12 Commits
5b84406652
...
1.2.2
Author | SHA1 | Date | |
---|---|---|---|
9607f69e24 | |||
6d3709da51 | |||
1456b21f34 | |||
7343267d3c | |||
430af8aede | |||
9028a8c59d | |||
daefbe884c | |||
9ad385e044 | |||
9b926634cf | |||
320739411a | |||
cffc90dfc9 | |||
3c5020b80b |
@@ -2,7 +2,7 @@
|
||||
"name": "maiyoule/mqttclient_author",
|
||||
"type": "library",
|
||||
"description": "MQTT管理模块操作库",
|
||||
"version": "1.1.1",
|
||||
"version": "1.2.2",
|
||||
"license": "MIT",
|
||||
"authors": [
|
||||
{
|
||||
|
@@ -162,7 +162,7 @@ class AuthorServerClient
|
||||
return new BizResponse();
|
||||
}
|
||||
$data = json_decode($content, true);
|
||||
return new BizResponse($data['code'] ?? 0, $data['message'] ?? '', $data['data'] ?? []);
|
||||
return new BizResponse($data['code'] ?? 0, $data['message'] ?? '', $data['data'] ?? [], $data['err'] ?? '');
|
||||
|
||||
} catch (ClientException $e) {
|
||||
$body = $e->getResponse()->getBody()->getContents();
|
||||
|
@@ -18,25 +18,60 @@ class AppUserCreateRequest extends IRequest
|
||||
'password' => $this->getPassword(),
|
||||
'fettle' => $this->getFettle(),
|
||||
'role' => $this->getRole(),
|
||||
'biz' => join(',', $this->getBiz())
|
||||
'publish' => join(',', $this->getPublish()),
|
||||
'subscribe' => join(',', $this->getSubscribe()),
|
||||
'expire' => $this->expireAt
|
||||
];
|
||||
}
|
||||
|
||||
private array $biz = [];
|
||||
private array $subscribe = [];
|
||||
|
||||
public function getBiz(): array
|
||||
public function getSubscribe(): array
|
||||
{
|
||||
return $this->biz;
|
||||
return $this->subscribe;
|
||||
}
|
||||
|
||||
public function setBiz(array|string $biz): void
|
||||
public function setSubscribe(array|string $subscribe): void
|
||||
{
|
||||
if (is_string($biz)) {
|
||||
$biz = [$biz];
|
||||
if (is_string($subscribe)) {
|
||||
$subscribe = [$subscribe];
|
||||
}
|
||||
$this->biz = $biz;
|
||||
$this->subscribe = $subscribe;
|
||||
}
|
||||
|
||||
/**
|
||||
* @var string 过期时间
|
||||
*/
|
||||
private string $expireAt = '';
|
||||
|
||||
public function getExpireAt(): string
|
||||
{
|
||||
return $this->expireAt;
|
||||
}
|
||||
|
||||
public function setExpireAt(string $expireAt): void
|
||||
{
|
||||
$this->expireAt = $expireAt;
|
||||
}
|
||||
|
||||
|
||||
private array $publish = [];
|
||||
|
||||
public function getPublish(): array
|
||||
{
|
||||
return $this->publish;
|
||||
}
|
||||
|
||||
public function setPublish(array|string $publish): void
|
||||
{
|
||||
if (is_string($publish)) {
|
||||
$publish = [$publish];
|
||||
}
|
||||
|
||||
$this->publish = $publish;
|
||||
}
|
||||
|
||||
|
||||
private string $password = '';
|
||||
private string $fettle = '';
|
||||
private string $role = 'user';
|
||||
|
@@ -29,23 +29,37 @@ class AppUserUpdateRequest extends IRequest
|
||||
if (!is_null($this->fettle)) {
|
||||
$data['fettle'] = $this->fettle;
|
||||
}
|
||||
if (!is_null($this->biz)) {
|
||||
$data['biz'] = join(',', $this->biz);
|
||||
if (!empty($this->publish)) {
|
||||
$data['publish'] = join(',', $this->getPublish());
|
||||
}
|
||||
if (!empty($this->subscribe)) {
|
||||
$data['subscribe'] = join(',', $this->getSubscribe());
|
||||
}
|
||||
|
||||
return $data;
|
||||
}
|
||||
|
||||
private ?array $biz = null;
|
||||
private array $subscribe = [];
|
||||
|
||||
public function getBiz(): array
|
||||
public function getSubscribe(): array
|
||||
{
|
||||
return $this->biz;
|
||||
return $this->subscribe;
|
||||
}
|
||||
|
||||
public function setBiz(array $biz): void
|
||||
public function setSubscribe(array|string $subscribe): void
|
||||
{
|
||||
$this->biz = $biz;
|
||||
if (is_string($subscribe)) {
|
||||
$subscribe = [$subscribe];
|
||||
}
|
||||
$this->subscribe = $subscribe;
|
||||
}
|
||||
|
||||
|
||||
private array $publish = [];
|
||||
|
||||
public function getPublish(): array
|
||||
{
|
||||
return $this->publish;
|
||||
}
|
||||
|
||||
private string $username;
|
||||
|
@@ -6,19 +6,22 @@ class BizResponse
|
||||
{
|
||||
private int $code;
|
||||
private string $message;
|
||||
private $data;
|
||||
private mixed $data;
|
||||
|
||||
private string $errCode;
|
||||
|
||||
/**
|
||||
* @param int $code
|
||||
* @param string $message
|
||||
* @param $data
|
||||
* @param array $data
|
||||
* @param string $errCode
|
||||
*/
|
||||
public function __construct(int $code = -1, string $message = '', $data = [])
|
||||
public function __construct(int $code = -1, string $message = '', mixed $data = [], string $errCode = '')
|
||||
{
|
||||
$this->code = $code;
|
||||
$this->message = $message;
|
||||
$this->data = $data;
|
||||
$this->errCode = $errCode;
|
||||
}
|
||||
|
||||
public function isSuccess(): bool
|
||||
@@ -49,7 +52,7 @@ class BizResponse
|
||||
/**
|
||||
* @return mixed
|
||||
*/
|
||||
public function getData()
|
||||
public function getData(): mixed
|
||||
{
|
||||
return $this->data;
|
||||
}
|
||||
@@ -62,5 +65,15 @@ class BizResponse
|
||||
$this->data = $data;
|
||||
}
|
||||
|
||||
public function getErrCode(): string
|
||||
{
|
||||
return $this->errCode;
|
||||
}
|
||||
|
||||
public function setErrCode(string $errCode): void
|
||||
{
|
||||
$this->errCode = $errCode;
|
||||
}
|
||||
|
||||
|
||||
}
|
Reference in New Issue
Block a user