<?php
namespace app\common\service;
use app\common\library\elasticsearch\Client;
use app\common\model\GoodsCategoryRel;
use app\common\model\Goods;
use think\Exception;
use app\common\library\helper;
class GoodsCateEs
{
private Client $esService;
private string $index_name = 'goods_category';
private string $field = 'goods_name,goods_id,category_id,goods_price_min,profit,profit_rate,status,create_time,goods_no,sort,store_id';
public function __construct()
{
$this->esService = Client::setEs($this->index_name);
}
/**
* 商品列表
* [list description]
* @param array $params [description]
* @param integer $page [description]
* @param integer $limit [description]
* @return [type] [description]
*/
public function list(array $params = [],$page = 1, $limit = 10)
{
$between = $ins = $orlike = $equal = [];
//商品名称like查询
if (isset($params['keyword']) && $params['keyword']) {
$orlike[] = ['goods_name' => $params['keyword'] ?? ''];
$orlike[] = ['goods_no' => $params['keyword'] ?? ''];
}
$equal[] = ['is_delete' => 0];
//等于查询
if (isset($params['status']) && $params['status']) {
$equal[] = ['status' => $params['status'] ?? 0];
}
if (isset($params['store_id']) && $params['store_id']) {
$equal[] = ['store_id' => $params['store_id'] ?? 0];
}
// if (isset($params['categoryId']) && $params['categoryId']) {
// $equal[] = ['store_id' => $params['categoryId'] ?? 0];
// }
//between查询
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']
];
}
}
//in查询
if (isset($params['channels']) && !empty($params['channels'])) {
$ins[] = ['channel' => $params['channels']];
}
$sort = $this->setQuerySort($params);
$data = $this->esService
->select($this->field)
->orlike($orlike)
->hasChild($between)
->in($ins)
->equal($equal)
->from($page)
->size($limit)
->order($sort)
//->setDebug()
->query();
if ($data['data']) {
$model = new Goods;
$goods_ids = array_column($data['data'], "goods_id");
$goods_list = array_column($data['data'], null, "goods_id");
$list = $model->getListByIds($goods_ids, 10);
if ($list) {
foreach ($list as &$value) {
$value['highlight_goods_name'] = $goods_list[$value['goods_id']]['highlight_goods_name'] ?? "";
}
}
$data['data'] = $list;
}
return $data;
}
/**
* 检索排序条件
* @param array $param
* @return array|string[]
*/
private function setQuerySort(array $param = []): array
{
$params = helper::setQueryDefaultValue($param, [
'sortType' => 'all', // 排序类型 (all默认 sales销量 price价格)
'sortPrice' => false, // 价格排序 (true高到低 false低到高)
]);
//var_dump($params);
// 排序规则
$sort = [];
if ($params['sortType'] === 'all') {
$sort[] = ['sort' => 'asc'];
} elseif ($params['sortType'] === 'sales') {
$sort[] = ['goods_sales' => 'desc'];
} elseif ($params['sortType'] === 'price') {
$sort[] = $params['sortPrice'] ? ['goods_price_min' => 'desc'] : ['goods_price_min' => 'asc'];
}
$sort[] = ["goods_id" => 'desc'];
return $sort;
}
/**
* 计算总数
* [count description]
* @param array $params [description]
* @param integer $page [description]
* @param integer $limit [description]
* @return [type] [description]
*/
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;
}
/**
* 批量创建商品分类
* [batchCreateGoodsCategory description]
* @param integer $goods_cate_id [description]
* @return [type] [description]
*/
public function batchCreateGoodsCategory($goods_cate_id = 0){
while (TRUE) {
$goods_cate_list = GoodsCategoryRel::where('id', '>', $goods_cate_id)
->where('category_id', '>', 0)
->where('goods_id', '>', 0)
->order('id desc')
->limit(1000)
->select()
->toArray();
if (!$goods_cate_list) {
return false;
}
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'){
echo('商品分类同步成功'.$value['id'].'条数据').PHP_EOL;
}
}
$goods_cate_id = end($goods_cate_list)['id'];
}
}
/**
* 批量创建商品
* [batchCreateGoods description]
* @param integer $goods_id [description]
* @return [type] [description]
*/
public function batchCreateGoods($goods_id = 0){
while (TRUE) {
$goods_list = Goods::where('goods_id', '>', $goods_id)
->order('goods_id asc')
->limit(1000)
->select()
->toArray();
// dd($goods_list);
if (!$goods_list) {
return false;
}
$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'){
echo('商品同步成功'.$value['goods_id'].'条数据').PHP_EOL;
}
}
$goods_id = end($goods_list)['goods_id'];
}
}
/**
* 删除商品
*/
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);
}
}