Compare commits
13 Commits
5b84406652
...
develop
Author | SHA1 | Date | |
---|---|---|---|
2801dec5b9 | |||
9607f69e24 | |||
6d3709da51 | |||
1456b21f34 | |||
7343267d3c | |||
430af8aede | |||
9028a8c59d | |||
daefbe884c | |||
9ad385e044 | |||
9b926634cf | |||
320739411a | |||
cffc90dfc9 | |||
3c5020b80b |
@@ -2,7 +2,7 @@
|
|||||||
"name": "maiyoule/mqttclient_author",
|
"name": "maiyoule/mqttclient_author",
|
||||||
"type": "library",
|
"type": "library",
|
||||||
"description": "MQTT管理模块操作库",
|
"description": "MQTT管理模块操作库",
|
||||||
"version": "1.1.1",
|
"version": "1.2.2",
|
||||||
"license": "MIT",
|
"license": "MIT",
|
||||||
"authors": [
|
"authors": [
|
||||||
{
|
{
|
||||||
|
@@ -162,7 +162,7 @@ class AuthorServerClient
|
|||||||
return new BizResponse();
|
return new BizResponse();
|
||||||
}
|
}
|
||||||
$data = json_decode($content, true);
|
$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) {
|
} catch (ClientException $e) {
|
||||||
$body = $e->getResponse()->getBody()->getContents();
|
$body = $e->getResponse()->getBody()->getContents();
|
||||||
|
@@ -18,25 +18,60 @@ class AppUserCreateRequest extends IRequest
|
|||||||
'password' => $this->getPassword(),
|
'password' => $this->getPassword(),
|
||||||
'fettle' => $this->getFettle(),
|
'fettle' => $this->getFettle(),
|
||||||
'role' => $this->getRole(),
|
'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)) {
|
if (is_string($subscribe)) {
|
||||||
$biz = [$biz];
|
$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 $password = '';
|
||||||
private string $fettle = '';
|
private string $fettle = '';
|
||||||
private string $role = 'user';
|
private string $role = 'user';
|
||||||
|
@@ -29,23 +29,37 @@ class AppUserUpdateRequest extends IRequest
|
|||||||
if (!is_null($this->fettle)) {
|
if (!is_null($this->fettle)) {
|
||||||
$data['fettle'] = $this->fettle;
|
$data['fettle'] = $this->fettle;
|
||||||
}
|
}
|
||||||
if (!is_null($this->biz)) {
|
if (!empty($this->publish)) {
|
||||||
$data['biz'] = join(',', $this->biz);
|
$data['publish'] = join(',', $this->getPublish());
|
||||||
|
}
|
||||||
|
if (!empty($this->subscribe)) {
|
||||||
|
$data['subscribe'] = join(',', $this->getSubscribe());
|
||||||
}
|
}
|
||||||
|
|
||||||
return $data;
|
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;
|
private string $username;
|
||||||
|
@@ -6,19 +6,22 @@ class BizResponse
|
|||||||
{
|
{
|
||||||
private int $code;
|
private int $code;
|
||||||
private string $message;
|
private string $message;
|
||||||
private $data;
|
private mixed $data;
|
||||||
|
|
||||||
|
private string $errCode;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @param int $code
|
* @param int $code
|
||||||
* @param string $message
|
* @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->code = $code;
|
||||||
$this->message = $message;
|
$this->message = $message;
|
||||||
$this->data = $data;
|
$this->data = $data;
|
||||||
|
$this->errCode = $errCode;
|
||||||
}
|
}
|
||||||
|
|
||||||
public function isSuccess(): bool
|
public function isSuccess(): bool
|
||||||
@@ -49,7 +52,7 @@ class BizResponse
|
|||||||
/**
|
/**
|
||||||
* @return mixed
|
* @return mixed
|
||||||
*/
|
*/
|
||||||
public function getData()
|
public function getData(): mixed
|
||||||
{
|
{
|
||||||
return $this->data;
|
return $this->data;
|
||||||
}
|
}
|
||||||
@@ -62,5 +65,15 @@ class BizResponse
|
|||||||
$this->data = $data;
|
$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