公眾號有幾十萬粉絲，如何在對接的時(shí)候快速同步到本地?cái)?shù)據(jù)庫進(jìn)行運(yùn)營

我使用EasyWechat嘗試開發(fā)了一個(gè)第三方平臺，然后會幫助本地商戶或公眾號運(yùn)營一些活動(dòng)，如何在公眾號授權(quán)對接后快速的將公眾號粉絲數(shù)據(jù)同步到本地?cái)?shù)據(jù)庫方便運(yùn)營？我先前的想法是用戶有交互的時(shí)候再觸發(fā)同步，目前是使用的手動(dòng)方式和命令行方式，手動(dòng)方式如下：

/**
     * 同步
     */
    public function sync()
    {
        $account = $this->request->param('account', 0, 'intval');
        $account = AccountService::getDataById($account);
        if (empty($account)) {
            $this->error('參數(shù)錯(cuò)誤');
        }
        //頁碼
        $page = $this->request->param('page', 0, 'intval');
        $page_size = 50;
        //微信實(shí)例
        $wechat = WechatService::applicationInit($account);
        
        //先從緩存中讀取
        $fans = cache('wechat_fans_'.$account->id);
        if (!$fans) {
            echo '從騰訊拉取';
            //從騰訊拉取第一頁
            $datas = $wechat->user->lists();
            $total = ceil($datas['total'] / $datas['count']);
            $fans = $datas['data']['openid'];
            for ($i = 1; $i < $total; $i++) {
                $datas = $wechat->user->lists($datas['next_openid']);
                $lists = $datas['data']['openid'];
                foreach ($lists as $k => $v) {
                    array_push($fans, $v);
                }
            }
            //設(shè)置緩存
            cache('wechat_fans_'.$account->id, $fans);
        }
        foreach ($fans as $k => $v) {
            if ($k <= $page * $page_size) {
                continue;
            }
            if ($k > ($page + 1) * $page_size) {
                return $this->success('更新下一頁', url($this->request->controller().'/sync', ['account' => $account->id, 'page' => $page + 1]));
            }
            echo '同步'.$k.'成功<br/>';
            try {
                UserService::syncDataByServer($account, $v);
            } catch (\Exception $e) {
                echo '同步'.$k.'出錯(cuò)<br/>';
                continue;
            }
        }
        //刪除緩存
        cache('wechat_fans_'.$account->id, null);
        return $this->success('同步完成', url($this->request->controller().'/index', ['account' => $account->id]));
    }

這種使用分頁同步在瀏覽器執(zhí)行的方式速度非常慢，大約幾萬粉絲都要跑很久，然后跟這個(gè)類似的我寫了一個(gè)命令行方式，執(zhí)行也很慢。

<php
namespace app\wechat\command;
use app\wechat\service\AccountService;
use app\wechat\service\WechatService;
use app\wechat\service\UserService;
use think\console\Command;
use think\console\Input;
use think\console\Output;
use think\console\input\Option;

/**
 * 同步用戶命令
 * Class SyncUser
 * @package app\wechat\command
 */
class SyncUser extends Command
{
    /**
     * 命令行配置
     */
    protected function configure()
    {
        //設(shè)置命令名稱及描述
        $this->setName('Wechat:SyncUser')
            ->addOption('account', 0, Option::VALUE_REQUIRED, '賬號ID.')
            ->setDescription('同步公眾號用戶');
    }

    /**
     * 命令
     * @return int|null|void
     */
    protected function execute(Input $input, Output $output)
    {
        ini_set('memory_limit', '1024M');
        if (!$input->hasOption('account')) {
            $output->writeln("請輸入賬號");
            return null;
        }
        $account = $input->getOption('account');
        $account = AccountService::getDataById($account);
        if (!$account) {
            $output->writeln("參數(shù)錯(cuò)誤");
            exit;
        }
        //微信實(shí)例
        $wechat = WechatService::applicationInit($account);
        //先從緩存中讀取
        $fans = cache('wechat_fans_'.$account->id);
        if (!$fans) {
            $output->writeln("從騰訊拉取粉絲");
            //從騰訊拉取第一頁
            $datas = $wechat->user->lists();
            $total = ceil($datas['total'] / $datas['count']);
            $fans = $datas['data']['openid'];
            for ($i = 1; $i < $total; $i++) {
                $datas = $wechat->user->lists($datas['next_openid']);
                $lists = $datas['data']['openid'];
                foreach ($lists as $k => $v) {
                    array_push($fans, $v);
                }
            }
            //設(shè)置緩存
            cache('wechat_fans_'.$account->id, $fans);
        }
        foreach ($fans as $k => $v) {
            try {
                UserService::syncDataByServer($account, $v);
            } catch (\Exception $e) {
                $output->writeln("同步{$k}出錯(cuò)");
                continue;
            }
        }
        //刪除緩存
        cache('wechat_fans_'.$account->id, null);
        $output->writeln("同步完成");
    }
}

求教各位大神有沒有比較好的方案。麻煩詳細(xì)些，本人不是專業(yè)的程序員，太簡略了看不懂。謝謝！