diff --git a/application/service/queue/WechatQueue.php b/application/service/queue/WechatQueue.php
index 1c7066dcf..2c35804ae 100644
--- a/application/service/queue/WechatQueue.php
+++ b/application/service/queue/WechatQueue.php
@@ -28,11 +28,6 @@ use think\Db;
  */
 class WechatQueue extends Queue
 {
-    /**
-     * 当前任务URI
-     */
-    const URI = self::class;
-
     /**
      * 当前操作APPID
      * @var string
@@ -51,27 +46,30 @@ class WechatQueue extends Queue
      */
     public function execute(Input $input, Output $output, array $data)
     {
-
         $this->appid = $data['appid'];
         $wechat = WechatService::WeChatUser($this->appid);
-        $next = ''; // 获取远程粉丝
+        // 获取远程粉丝
+        list($next, $done) = ['', 0];
         $output->writeln('Start synchronizing fans from the Wechat server');
-        while (is_array($result = $wechat->getUserList($next)) && !empty($result['data']['openid'])) {
-            foreach (array_chunk($result['data']['openid'], 100) as $chunk)
-                if (is_array($list = $wechat->getBatchUserInfo($chunk)) && !empty($list['user_info_list']))
+        while (!is_null($next) && is_array($result = $wechat->getUserList($next)) && !empty($result['data']['openid'])) {
+            $done += $result['count'];
+            foreach (array_chunk($result['data']['openid'], 100) as $chunk) {
+                if (is_array($list = $wechat->getBatchUserInfo($chunk)) && !empty($list['user_info_list'])) {
                     foreach ($list['user_info_list'] as $user) FansService::set($user, $this->appid);
-            if (in_array($result['next_openid'], $result['data']['openid'])) break;
-            $next = $result['next_openid'];
+                }
+            }
+            $next = $result['total'] > $done ? $result['next_openid'] : null;
         }
-        $next = ''; // 同步粉丝黑名单
+        // 同步粉丝黑名单
+        list($next, $done) = ['', 0];
         $output->writeln('Start synchronizing black from the Wechat server');
-        while (is_array($result = $wechat->getBlackList($next)) && !empty($result['data']['openid'])) {
+        while (!is_null($next) && is_array($result = $wechat->getBlackList($next)) && !empty($result['data']['openid'])) {
+            $done += $result['count'];
             foreach (array_chunk($result['data']['openid'], 100) as $chunk) {
                 $where = [['is_black', 'eq', '0'], ['openid', 'in', $chunk]];
                 Db::name('WechatFans')->where($where)->update(['is_black' => '1']);
             }
-            if (in_array($result['next_openid'], $result['data']['openid'])) break;
-            $next = $result['next_openid'];
+            $next = $result['total'] > $done ? $result['next_openid'] : null;
         }
         // 同步粉丝标签列表
         $output->writeln('Start synchronizing tags from the Wechat server');
diff --git a/application/wechat/command/Fans.php b/application/wechat/command/Fans.php
index ef54d63c8..0c38d994f 100644
--- a/application/wechat/command/Fans.php
+++ b/application/wechat/command/Fans.php
@@ -43,11 +43,9 @@ class Fans extends Command
      */
     protected function execute(Input $input, Output $output)
     {
-        # $output->writeln('preparing for synchronization of fan command...');
         foreach ($this->module as $m) {
             if (method_exists($this, $fun = "_{$m}")) $this->$fun();
         }
-        # $output->writeln('synchronized fans command completion.');
     }
 
 
@@ -64,20 +62,21 @@ class Fans extends Command
     {
         $appid = WechatService::getAppid();
         $wechat = WechatService::WeChatUser();
-        $this->output->comment('preparing synchronize fans list ...');
-        while ($next !== null && is_array($result = $wechat->getUserList($next)) && !empty($result['data']['openid'])) {
+        $this->output->comment('开始同步微信粉丝数据 ...');
+        while (!is_null($next) && is_array($result = $wechat->getUserList($next)) && !empty($result['data']['openid'])) {
             foreach (array_chunk($result['data']['openid'], 100) as $chunk) {
                 if (is_array($list = $wechat->getBatchUserInfo($chunk)) && !empty($list['user_info_list'])) {
                     foreach ($list['user_info_list'] as $user) {
                         $indexString = str_pad(++$done, strlen($result['total']), '0', STR_PAD_LEFT);
-                        $this->output->writeln("({$indexString}/{$result['total']}) updating wechat user {$user['openid']} {$user['nickname']}");
+                        $this->output->writeln("({$indexString}/{$result['total']}) 正在更新粉丝 {$user['openid']} {$user['nickname']}");
                         \app\wechat\service\FansService::set($user, $appid);
                     }
                 }
             }
             $next = $result['total'] > $done ? $result['next_openid'] : null;
         }
-        $this->output->comment('synchronized fans list successful.');
+        $this->output->comment('微信粉丝数据同步完成');
+        $this->output->newLine();
     }
 
     /**
@@ -92,18 +91,17 @@ class Fans extends Command
     public function _black($next = '', $done = 0)
     {
         $wechat = WechatService::WeChatUser();
-        $this->output->comment('prepare synchronize fans black ...');
-        while ($next !== null && is_array($result = $wechat->getBlackList($next)) && !empty($result['data']['openid'])) {
+        $this->output->comment('开始同步微信黑名单数据 ...');
+        while (!is_null($next) && is_array($result = $wechat->getBlackList($next)) && !empty($result['data']['openid'])) {
+            $done += $result['count'];
             foreach (array_chunk($result['data']['openid'], 100) as $chunk) {
-                foreach ($chunk as $openid) {
-                    $indexString = str_pad(++$done, strlen($result['total']), '0', STR_PAD_LEFT);
-                    $this->output->writeln("({$indexString}/{$result['total']}) updating wechat black {$openid}");
-                }
                 Db::name('WechatFans')->where(['is_black' => '0'])->whereIn('openid', $chunk)->update(['is_black' => '1']);
             }
+            $this->output->writeln("--> 共计同步微信黑名单{$result['total']}人");
             $next = $result['total'] > $done ? $result['next_openid'] : null;
         }
-        $this->output->comment('synchronized fans black successful.');
+        $this->output->comment('微信黑名单数据同步完成');
+        $this->output->newLine();
     }
 
     /**
@@ -118,18 +116,19 @@ class Fans extends Command
     {
         $appid = WechatService::getAppid();
         $wechat = WechatService::WeChatTags();
-        $this->output->comment('prepare synchronize fans tags ...');
+        $this->output->comment('同步微信粉丝标签数据...');
         if (is_array($list = $wechat->getTags()) && !empty($list['tags'])) {
             $count = count($list['tags']);
             foreach ($list['tags'] as &$tag) {
                 $tag['appid'] = $appid;
                 $indexString = str_pad(++$index, strlen($count), '0', STR_PAD_LEFT);
-                $this->output->writeln("({$indexString}/{$count}) updating wechat tags {$tag['name']}");
+                $this->output->writeln("({$indexString}/{$count}) 更新粉丝标签 {$tag['name']}");
             }
             Db::name('WechatFansTags')->where(['appid' => $appid])->delete();
             Db::name('WechatFansTags')->insertAll($list['tags']);
         }
-        $this->output->comment('synchronized fans tags successful.');
+        $this->output->comment('微信粉丝标签数据同步完成');
+        $this->output->newLine();
     }
 
 }
diff --git a/application/wechat/queue/WechatQueue.php b/application/wechat/queue/WechatQueue.php
index 6211eb9e8..f0fbf446b 100644
--- a/application/wechat/queue/WechatQueue.php
+++ b/application/wechat/queue/WechatQueue.php
@@ -28,17 +28,12 @@ use think\Db;
  */
 class WechatQueue extends Queue
 {
-    /**
-     * 当前任务URI
-     */
-    const URI = self::class;
 
     /**
      * 执行任务
      * @param Input $input
      * @param Output $output
      * @param array $data
-     * @return boolean
      * @throws \WeChat\Exceptions\InvalidResponseException
      * @throws \WeChat\Exceptions\LocalCacheException
      * @throws \think\Exception
@@ -50,8 +45,7 @@ class WechatQueue extends Queue
         $wechat = WechatService::WeChatUser();
         // 获取远程粉丝
         list($next, $done) = ['', 0];
-        $output->writeln('Start synchronizing fans from the Wechat server');
-        while ($next !== null && is_array($result = $wechat->getUserList($next)) && !empty($result['data']['openid'])) {
+        while (!is_null($next) && is_array($result = $wechat->getUserList($next)) && !empty($result['data']['openid'])) {
             $done += $result['count'];
             foreach (array_chunk($result['data']['openid'], 100) as $chunk) {
                 if (is_array($list = $wechat->getBatchUserInfo($chunk)) && !empty($list['user_info_list'])) {
@@ -62,16 +56,14 @@ class WechatQueue extends Queue
         }
         // 同步粉丝黑名单
         list($next, $done) = ['', 0];
-        $output->writeln('Start synchronizing black from the Wechat server');
-        while ($next !== null && is_array($result = $wechat->getBlackList($next)) && !empty($result['data']['openid'])) {
+        while (!is_null($next) && is_array($result = $wechat->getBlackList($next)) && !empty($result['data']['openid'])) {
             $done += $result['count'];
             foreach (array_chunk($result['data']['openid'], 100) as $chunk) {
                 Db::name('WechatFans')->where(['is_black' => '0'])->whereIn('openid', $chunk)->update(['is_black' => '1']);
             }
             $next = $result['total'] > $done ? $result['next_openid'] : null;
         }
-        // 同步粉丝标签列表
-        $output->writeln('Start synchronizing tags from the Wechat server');
+        // 同步粉丝标签
         if (is_array($list = WechatService::WeChatTags()->getTags()) && !empty($list['tags'])) {
             foreach ($list['tags'] as &$tag) $tag['appid'] = $appid;
             Db::name('WechatFansTags')->where('1=1')->delete();