beauti-nof/application/common/command/EsImportCommand.php

<?php
namespace app\common\command;

use app\common\model\Mobile;
use app\service\EsMobileService;
use think\console\Command;
use think\console\Input;
use think\console\Output;

class EsImportCommand extends Command{
    protected function configure()
    {
        $this->setName('es:import')->setDescription('test');
    }

    protected function execute(Input $input, Output $output)
    {
        $count=es()->count([
            'index'=>'mobiles',
            'body'=>[
                'query'=>[
                    'term'=>[
                        'type'=>['value'=>1]
                    ]
                ]
            ]
        ]);
//        return $count->offsetGet('count');
        if($count->offsetGet('count') < 100000){
            $count=0;
            Mobile::where('type',1)->chunk(10000,function ($mobiles)use (&$count){
                EsMobileService::addMobiles($mobiles);
                $count+=count($mobiles);
                $this->output->info("count:{$count}");
            });
        }
    }
}