beauti-nof/application/common/command/DelMobileCommand.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;
use think\Db;

class DelMobileCommand extends Command{
    protected function configure()
    {
        $this->setName('del:mobile')->setDescription('订单超时关闭');
    }

    protected function execute(Input $input, Output $output)
    {
//        for ($i=135377576;$i<135951454;$i++){
//            $exists=Mobile::where('id',$i)->value('id');
//            try {
//                $existsInEs=es()->get([
//                    'index'=>EsMobileService::index(),
//                    'id'=>$i
//                ]);
//            }catch (\Exception $exception){
//                $existsInEs=false;
//            }
//            if($exists && $existsInEs){
//                EsMobileService::delMobiles([$i]);
//                $this->output->info("删除号码：".$i);
//                user_log('DelMobileCommand',$i);
//            }
//        }
        $count=0;
        Mobile::where('type',1)->where('id','<',137372423)->chunk(10000,function ($mobiles)use (&$count){
            foreach ($mobiles as $mobile){
                try {
                    $existsInEs=es()->get([
                        'index'=>EsMobileService::index(),
                        'id'=>$mobile['id']
                    ]);
                }catch (\Exception $exception){
                    $existsInEs=false;
                }
                if($existsInEs){
                    EsMobileService::delMobiles([$mobile['id']]);
                    $count+=1;
                    $this->output->info($count);
                    user_log('DelMobileCommand',$mobile['id']);
                }else {
                    // $this->output->info($mobiles);
                    // print_r($mobile);
                }
            }
        });
    }
}