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.
533 lines
15 KiB
533 lines
15 KiB
<?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);
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
} |