ztt
6 months ago
commit
061b624010
@ -0,0 +1,533 @@ |
||||
<?php |
||||
|
||||
namespace app\common\service; |
||||
|
||||
use app\common\library\elasticsearch\Client; |
||||
use app\common\model\GoodsCategoryRel; |
||||
use app\common\model\Goods; |
||||
use think\Exception; |
||||
|
||||
class GoodsCateEs |
||||
{ |
||||
private Client $esService; |
||||
|
||||
private string $index_name = 'goods_category'; |
||||
|
||||
private string $field = 'goods_name,goods_id,category_id,profit,profit_rate,status,create_time'; |
||||
|
||||
public function __construct() |
||||
{ |
||||
$this->esService = Client::setEs($this->index_name); |
||||
} |
||||
|
||||
|
||||
/** |
||||
* 查询分类列表 |
||||
* @param $params |
||||
*/ |
||||
public function list(array $params = [],$page = 1, $limit = 10) |
||||
{ |
||||
$between = $ins = []; |
||||
$like = ['goods_name' => $params['goods_name'] ?? '']; |
||||
$equal = ['status' => $params['status']]; |
||||
if (isset($params['fliter_condition']) && $params['fliter_condition']) { |
||||
$fliter_condition = json_decode($params['fliter_condition'], true); |
||||
foreach ($fliter_condition as $key => $value) |
||||
{ |
||||
$between[] = [ |
||||
'category_id' => $value['category'], |
||||
'profit' => $value['profit'], |
||||
'profit_rate' => $value['profit_rate'] |
||||
]; |
||||
} |
||||
unset($params['fliter_condition']); |
||||
|
||||
} |
||||
|
||||
if (!empty($params['channels'])) { |
||||
$ins = ['channels' => $params['channels']]; |
||||
unset($params['channels']); |
||||
} |
||||
|
||||
return $this->esService |
||||
->select($this->field) |
||||
->like($like) |
||||
->hasChild($between) |
||||
->in($ins) |
||||
->equal($equal) |
||||
->from($page) |
||||
->size($limit) |
||||
->order(['goods_id' => 'desc']) |
||||
// ->setDebug() |
||||
->query(); |
||||
} |
||||
|
||||
public function count($params = [],$page = 1, $limit = 10) |
||||
{ |
||||
$between = $ins = []; |
||||
$like = ['goods_name' => $params['goods_name'] ?? '']; |
||||
$equal = ['status' => $params['status']]; |
||||
if (isset($params['fliter_condition']) && $params['fliter_condition']) { |
||||
$fliter_condition = json_decode($params['fliter_condition'], true); |
||||
foreach ($fliter_condition as $key => $value) |
||||
{ |
||||
$between[] = [ |
||||
'category_id' => $value['category'], |
||||
'profit' => $value['profit'], |
||||
'profit_rate' => $value['profit_rate'] |
||||
]; |
||||
} |
||||
unset($params['fliter_condition']); |
||||
|
||||
} |
||||
|
||||
if (!empty($params['channels'])) { |
||||
$ins = ['channels' => $params['channels']]; |
||||
unset($params['channels']); |
||||
} |
||||
return $this->esService |
||||
// ->setDebug() |
||||
->like($like) |
||||
->hasChild($between) |
||||
->in($ins) |
||||
->equal($equal) |
||||
->from($page) |
||||
->size($limit) |
||||
->query(true); |
||||
} |
||||
|
||||
|
||||
/** |
||||
* 更新商品 |
||||
*/ |
||||
public function updateData($goods_id, $data) |
||||
{ |
||||
return $this->esService->update($goods_id, $data); |
||||
} |
||||
|
||||
/** |
||||
* 查询商品详情 |
||||
*/ |
||||
public function detail($goods_id) |
||||
{ |
||||
return $this->esService->getDoc($goods_id); |
||||
} |
||||
|
||||
/** |
||||
* 创建商品 |
||||
*/ |
||||
public function createData($goods_id, $list) |
||||
{ |
||||
$list['goods_category_field'] = [ |
||||
'name' => 'goods' |
||||
]; |
||||
return $this->esService->addDoc('goods_'.$goods_id, $list)->asArray(); |
||||
} |
||||
|
||||
/** |
||||
* 创建商品分类 |
||||
*/ |
||||
public function createCateData($id, $value) |
||||
{ |
||||
|
||||
$parent_id = 'goods_'.$value['goods_id']; |
||||
$doc = [ |
||||
'id' => $value['id'], |
||||
'category_id' => $value['category_id'], |
||||
'cate_store_id' => $value['store_id'], |
||||
// 'cate_create_time' => strtotime($value['create_time']), |
||||
'cate_create_time' => $value['create_time'], |
||||
'goods_category_field' => [ |
||||
'name' => 'category', |
||||
'parent' => $parent_id |
||||
], |
||||
|
||||
]; |
||||
return $this->esService->addDoc('category_'.$id, $doc)->asArray(); |
||||
} |
||||
|
||||
|
||||
/** |
||||
* 批量创建数据 |
||||
* @return |
||||
*/ |
||||
public function batchCreateData() |
||||
{ |
||||
for ($page = 1; $page<=224; $page++) |
||||
{ |
||||
$this->addData($page); |
||||
// sleep(1); |
||||
} |
||||
} |
||||
|
||||
public function addData($page) |
||||
{ |
||||
$goods_cate_list = GoodsCategoryRel::where('category_id', '>', 0) |
||||
->where('id', '>', 1628858) |
||||
->where('goods_id', '>', 0) |
||||
// ->order('goods_id desc') |
||||
->page($page) |
||||
->limit(5000) |
||||
->select() |
||||
->toArray(); |
||||
// dd($goods_cate_list); |
||||
// |
||||
$i = 0; |
||||
if (!empty($goods_cate_list)){ |
||||
foreach ($goods_cate_list as $value) |
||||
{ |
||||
$parent_id = 'goods_'.$value['goods_id']; |
||||
$doc = [ |
||||
'id' => $value['id'], |
||||
'category_id' => $value['category_id'], |
||||
'cate_store_id' => $value['store_id'], |
||||
// 'cate_create_time' => strtotime($value['create_time']), |
||||
'cate_create_time' => $value['create_time'], |
||||
'goods_category_field' => [ |
||||
'name' => 'category', |
||||
'parent' => $parent_id |
||||
], |
||||
|
||||
]; |
||||
// dd($doc); |
||||
$res = $this->esService->addChildDoc('category_'.$value['id'], $parent_id, $doc)->asArray(); |
||||
if($res['result'] == 'created') |
||||
{ |
||||
$i++; |
||||
} |
||||
} |
||||
} |
||||
|
||||
echo('同步成功'.$i.'条数据').PHP_EOL; |
||||
} |
||||
|
||||
/** |
||||
* 批量创建商品 |
||||
* @return |
||||
*/ |
||||
public function batchCreateGoodsData() |
||||
{ |
||||
for ($page = 1; $page<=173; $page++) |
||||
{ |
||||
$this->addGoodsData($page); |
||||
// sleep(1); |
||||
} |
||||
} |
||||
|
||||
public function addGoodsData($page) |
||||
{ |
||||
$goods_list = Goods::where('goods_id', '>', 0) |
||||
// ->order('goods_id desc') |
||||
->page($page) |
||||
->limit(2000) |
||||
->select() |
||||
->toArray(); |
||||
// dd($goods_list); |
||||
// |
||||
$i = 0; |
||||
foreach ($goods_list as $value) |
||||
{ |
||||
// $value['create_time'] = $value['create_time']; |
||||
// $value['update_time'] = $value['update_time']; |
||||
$value['delivery_type'] = implode(',', $value['delivery_type']); |
||||
$value['goods_category_field'] = [ |
||||
'name' => 'goods' |
||||
]; |
||||
$res = $this->esService->addDoc('goods_'.$value['goods_id'], $value)->asArray(); |
||||
if($res['result'] == 'created') |
||||
{ |
||||
$i++; |
||||
} |
||||
} |
||||
|
||||
echo('同步成功'.$i.'条数据').PHP_EOL; |
||||
} |
||||
|
||||
/** |
||||
* 删除商品 |
||||
*/ |
||||
public function delete($goods_id) |
||||
{ |
||||
return $this->esService->deleteDoc($goods_id); |
||||
} |
||||
|
||||
/** |
||||
* 删除索引 |
||||
*/ |
||||
public function deleteIndex() |
||||
{ |
||||
return $this->esService->deleteIndexNew(); |
||||
} |
||||
|
||||
/** |
||||
* 创建商品分类关联索引 |
||||
*/ |
||||
public function createGoodsCateIndex() |
||||
{ |
||||
|
||||
$mapping = [ |
||||
'properties' => [ |
||||
'goods_id' => [ |
||||
'type' => 'keyword' |
||||
], |
||||
'goods_type' => [ |
||||
'type' => 'keyword' |
||||
], |
||||
'goods_name' => [ |
||||
'type' => 'text', |
||||
"analyzer" => "ik_smart" |
||||
], |
||||
'goods_no' => [ |
||||
'type' => 'keyword', |
||||
], |
||||
'video_id' => [ |
||||
'type' => 'integer' |
||||
], |
||||
'brand_id' => [ |
||||
'type' => 'integer' |
||||
], |
||||
'video_cover_id' => [ |
||||
'type' => 'integer' |
||||
], |
||||
'selling_point' => [ |
||||
'type' => 'text', |
||||
"analyzer" => "ik_smart" |
||||
], |
||||
'spec_type' => [ |
||||
'type' => 'integer' |
||||
], |
||||
'cost_price_min' => [ |
||||
'type' => 'float' |
||||
], |
||||
'goods_price_min' => [ |
||||
'type' => 'float' |
||||
], |
||||
'goods_price_max' => [ |
||||
'type' => 'float' |
||||
], |
||||
'line_price_min' => [ |
||||
'type' => 'float' |
||||
], |
||||
'line_price_max' => [ |
||||
'type' => 'float' |
||||
], |
||||
'stock_total' => [ |
||||
'type' => 'integer' |
||||
], |
||||
'deduct_stock_type' => [ |
||||
'type' => 'integer' |
||||
], |
||||
'is_restrict' => [ |
||||
'type' => 'integer' |
||||
], |
||||
'restrict_total' => [ |
||||
'type' => 'integer' |
||||
], |
||||
'restrict_single' => [ |
||||
'type' => 'integer' |
||||
], |
||||
'content' => [ |
||||
'type' => 'text', |
||||
], |
||||
'sales_initial' => [ |
||||
'type' => 'integer' |
||||
], |
||||
'delivery_id' => [ |
||||
'type' => 'integer' |
||||
], |
||||
'is_points_gift' => [ |
||||
'type' => 'integer' |
||||
], |
||||
'is_points_discount' => [ |
||||
'type' => 'integer' |
||||
], |
||||
'is_alone_points_discount' => [ |
||||
'type' => 'integer' |
||||
], |
||||
'points_discount_config' => [ |
||||
'type' => 'text' |
||||
], |
||||
'is_enable_grade' => [ |
||||
'type' => 'integer' |
||||
], |
||||
'is_alone_grade' => [ |
||||
'type' => 'integer' |
||||
], |
||||
'alone_grade_equity' => [ |
||||
'type' => 'text' |
||||
], |
||||
'is_ind_dealer' => [ |
||||
'type' => 'integer' |
||||
], |
||||
'dealer_money_type' => [ |
||||
'type' => 'integer' |
||||
], |
||||
'first_money' => [ |
||||
'type' => 'float' |
||||
], |
||||
'second_money' => [ |
||||
'type' => 'float' |
||||
], |
||||
'third_money' => [ |
||||
'type' => 'float' |
||||
], |
||||
'is_ind_delivery_type' => [ |
||||
'type' => 'integer' |
||||
], |
||||
'delivery_type' => [ |
||||
'type' => 'keyword' |
||||
], |
||||
'status' => [ |
||||
'type' => 'integer' |
||||
], |
||||
'sort' => [ |
||||
'type' => 'integer' |
||||
], |
||||
'store_id' => [ |
||||
'type' => 'keyword' |
||||
], |
||||
'merchant_id' => [ |
||||
'type' => 'keyword' |
||||
], |
||||
'create_time' => [ |
||||
'type' => 'date', |
||||
'format' => 'yyyy-MM-dd HH:mm:ss' |
||||
], |
||||
'update_time' => [ |
||||
'type' => 'date', |
||||
'format' => 'yyyy-MM-dd HH:mm:ss' |
||||
], |
||||
'is_brand' => [ |
||||
'type' => 'integer' |
||||
], |
||||
'is_new' => [ |
||||
'type' => 'integer' |
||||
], |
||||
'paihang' => [ |
||||
'type' => 'integer' |
||||
], |
||||
'remaizhishu' => [ |
||||
'type' => 'integer' |
||||
], |
||||
'spu_id' => [ |
||||
'type' => 'integer' |
||||
], |
||||
'channel' => [ |
||||
'type' => 'keyword' |
||||
], |
||||
'unicode' => [ |
||||
'type' => 'keyword' |
||||
], |
||||
'is_in_store' => [ |
||||
'type' => 'integer' |
||||
], |
||||
'profit' => [ |
||||
'type' => 'float' |
||||
], |
||||
'profit_rate' => [ |
||||
'type' => 'float' |
||||
], |
||||
'cmmdty_model'=> [ |
||||
'type' => 'keyword' |
||||
], |
||||
'remark' => [ |
||||
'type' => 'text' |
||||
], |
||||
'sale_areas' => [ |
||||
'type' => 'text' |
||||
], |
||||
'sale_areas_id' => [ |
||||
'type' => 'keyword' |
||||
], |
||||
'data_type' => [ |
||||
'type' => 'integer' |
||||
], |
||||
'is_pool' => [ |
||||
'type' => 'integer' |
||||
], |
||||
'is_self' => [ |
||||
'type' => 'integer' |
||||
], |
||||
'link' => [ |
||||
'type' => 'keyword' |
||||
], |
||||
'origin_goods_id' => [ |
||||
'type' => 'integer' |
||||
], |
||||
'link_other' => [ |
||||
'type' => 'text' |
||||
], |
||||
'goods_no_other' => [ |
||||
'type' => 'keyword' |
||||
], |
||||
'region' => [ |
||||
'type' => 'text' |
||||
], |
||||
'region_text' => [ |
||||
'type' => 'text' |
||||
], |
||||
'specific_value' => [ |
||||
'type' => 'keyword' |
||||
], |
||||
'cate_status' => [ |
||||
'type' => 'integer' |
||||
], |
||||
'is_check' => [ |
||||
'type' => 'integer' |
||||
], |
||||
'goods_source' => [ |
||||
'type' => 'keyword' |
||||
], |
||||
'delivery_time' => [ |
||||
'type' => 'integer' |
||||
], |
||||
'distribute_price' => [ |
||||
'type' => 'float' |
||||
], |
||||
'shop_price' => [ |
||||
'type' => 'float' |
||||
], |
||||
'is_has_banner' => [ |
||||
'type' => 'integer' |
||||
], |
||||
'is_has_detail' => [ |
||||
'type' => 'integer' |
||||
], |
||||
'is_jingpin' => [ |
||||
'type' => 'integer' |
||||
], |
||||
'sale_time' => [ |
||||
'type' => 'integer' |
||||
], |
||||
'markup_rate' => [ |
||||
'type' => 'integer' |
||||
], |
||||
'id' => [ |
||||
'type' => 'integer' |
||||
], |
||||
'category_id' => [ |
||||
'type' => 'integer' |
||||
], |
||||
'cate_store_id' => [ |
||||
'type' => 'integer' |
||||
], |
||||
'cate_create_time' => [ |
||||
'type' => 'integer' |
||||
], |
||||
'goods_category_field' => [ |
||||
'type' => 'join', |
||||
'relations' => [ |
||||
'goods' => 'category' |
||||
] |
||||
] |
||||
] |
||||
]; |
||||
|
||||
return $this->esService->createIndexNew($mapping); |
||||
|
||||
} |
||||
|
||||
|
||||
|
||||
|
||||
} |
||||
Loading…
Reference in new issue