You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
118 lines
2.2 KiB
118 lines
2.2 KiB
<?php
|
|
|
|
namespace App\Console\Commands;
|
|
|
|
use App\Models\Product;
|
|
use App\Models\SearchAble\ElasticSearchTrait;
|
|
use Elasticsearch\ClientBuilder;
|
|
use Illuminate\Console\Command;
|
|
use Illuminate\Database\Eloquent\Collection;
|
|
|
|
class AddShopToEsSearchCommand extends Command
|
|
{
|
|
/**
|
|
* The name and signature of the console command.
|
|
*
|
|
* @var string
|
|
*/
|
|
protected $signature = 'add:shop-to-search';
|
|
|
|
/**
|
|
* The console command description.
|
|
*
|
|
* @var string
|
|
*/
|
|
protected $description = '把商品添加到全文索引';
|
|
|
|
/**
|
|
* Create a new command instance.
|
|
*
|
|
* @return void
|
|
*/
|
|
|
|
|
|
public function __construct()
|
|
{
|
|
parent::__construct();
|
|
}
|
|
|
|
/**
|
|
* Execute the console command.
|
|
*
|
|
* @return mixed
|
|
*/
|
|
public function handle()
|
|
{
|
|
|
|
|
|
try {
|
|
|
|
ElasticSearchTrait::client()->ping([
|
|
'client' => [
|
|
'timeout' => 5,
|
|
|
|
'connect_timeout' => 5
|
|
]
|
|
]);
|
|
} catch (\Exception $exception) {
|
|
|
|
|
|
|
|
$this->info($exception->getMessage());
|
|
|
|
|
|
|
|
$this->info('无法连接到 elasticse
|
|
|
|
|
|
|
|
arch 服务器，请配置 config/elasticsearch.php 文件');
|
|
|
|
$this->info('默认使用 MySQL 的模糊搜索');
|
|
$this->info('配置完毕后可运行: php artisan add:shop-to-search 添加索引');
|
|
|
|
|
|
|
|
return;
|
|
}
|
|
|
|
|
|
// 新建商品索引
|
|
if (Product::indexExists()) {
|
|
|
|
|
|
|
|
Product::deleteIndex();
|
|
$this->info('删除索引');
|
|
}
|
|
|
|
Product::createIndex();
|
|
$this->info('新建索引成功');
|
|
|
|
|
|
|
|
// 开始导入数据
|
|
$query = Product::query();
|
|
|
|
$count = $query->count();
|
|
$handle = 0;
|
|
|
|
$query->with('category')->chunk(1000, function (Collection $models) use ($count, &$handle) {
|
|
|
|
$models->map(function (Product $product) use ($count, &$handle) {
|
|
|
|
$product->addToIndex($product->getSearchData());
|
|
|
|
++ $handle;
|
|
echo "\r {$handle}/$count";
|
|
});
|
|
});
|
|
|
|
|
|
|
|
echo PHP_EOL;
|
|
|
|
$this->info('索引生成完毕');
|
|
}
|
|
}
|