From 2cf7cbc6243be8ab3b7cb1287edf5e6a3726f665 Mon Sep 17 00:00:00 2001
From: "iVampireSP.com" <im@ivampiresp.com>
Date: Fri, 20 Jan 2023 00:59:08 +0800
Subject: [PATCH] =?UTF-8?q?=E6=94=B9=E8=BF=9B=20=E6=B8=85=E7=90=86?=
 =?UTF-8?q?=E8=A7=84=E5=88=99?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 app/Jobs/Support/EMQXKickClientJob.php | 14 +++++---------
 1 file changed, 5 insertions(+), 9 deletions(-)

diff --git a/app/Jobs/Support/EMQXKickClientJob.php b/app/Jobs/Support/EMQXKickClientJob.php
index ac5240a..1482256 100644
--- a/app/Jobs/Support/EMQXKickClientJob.php
+++ b/app/Jobs/Support/EMQXKickClientJob.php
@@ -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));
                 }
+
             }
         }
     }