改进 清理规则
This commit is contained in:
parent
d2e1cc23ef
commit
2cf7cbc624
@ -56,20 +56,16 @@ public function handle(): void
|
||||
return;
|
||||
}
|
||||
|
||||
if ($clients) {
|
||||
// 循环翻页
|
||||
for ($i = 1; $i <= $clients['meta']['count']; $i++) {
|
||||
try {
|
||||
$clients = $emqx->clients([$query => $this->username, 'page' => $i]);
|
||||
} catch (EmqxSupportException $e) {
|
||||
Log::error('emqx connect failed.', [$e]);
|
||||
continue;
|
||||
}
|
||||
|
||||
if ($clients) {
|
||||
if (count($clients['data']) > 0) {
|
||||
foreach ($clients['data'] as $client) {
|
||||
dispatch(new self($client['clientid'], null));
|
||||
}
|
||||
|
||||
dispatch(new self(null, $this->username, $this->like_username));
|
||||
}
|
||||
|
||||
}
|
||||
}
|
||||
}
|
||||
|
Loading…
Reference in New Issue
Block a user