lqmac
10 months ago
commit
4a5e8401b3
@ -0,0 +1,28 @@ |
||||
<?php |
||||
|
||||
namespace app\command; |
||||
|
||||
use app\common\service\GoodsEs; |
||||
use think\console\Command; |
||||
use think\console\Output; |
||||
use think\console\Input; |
||||
|
||||
class SyncGoodsToEs extends Command |
||||
{ |
||||
|
||||
protected function configure() |
||||
{ |
||||
// 指令配置 |
||||
$this->setName('syncGoodsToEs') |
||||
->setDescription('同步商品数据到ES'); |
||||
} |
||||
|
||||
|
||||
protected function execute(Input $input, Output $output) |
||||
{ |
||||
$goodsService = new GoodsEs(); |
||||
$goods = $goodsService->list([]); |
||||
var_dump($goods); |
||||
} |
||||
|
||||
} |
||||
@ -0,0 +1,751 @@ |
||||
<?php |
||||
namespace app\common\library\elasticsearch; |
||||
|
||||
use Elastic\Elasticsearch\ClientBuilder; |
||||
use think\Exception; |
||||
|
||||
class Client |
||||
{ |
||||
public $client; |
||||
|
||||
const ES_HOST_NAME = '114.55.95.135:9200'; |
||||
|
||||
|
||||
private static $instance; |
||||
|
||||
/** |
||||
* @var 索引名称 |
||||
*/ |
||||
protected $index; |
||||
|
||||
|
||||
public $alias; |
||||
|
||||
protected $retries = 2; |
||||
|
||||
/** |
||||
* 查询参数 |
||||
* @var array $queryParams |
||||
*/ |
||||
protected $queryParams = []; |
||||
|
||||
private $debug; |
||||
|
||||
public function __construct() |
||||
{ |
||||
|
||||
var_dump(self::ES_HOST_NAME); |
||||
$this->client = ClientBuilder::create()->setHosts([self::ES_HOST_NAME])->build(); |
||||
} |
||||
|
||||
|
||||
private function __clone() { |
||||
|
||||
} |
||||
|
||||
public static function getInstance(){ |
||||
if (is_null(self::$instance)) { |
||||
self::$instance = new self(); |
||||
} |
||||
return self::$instance; |
||||
} |
||||
|
||||
/** |
||||
* 查询条件 |
||||
* @param $params |
||||
* @return $this |
||||
*/ |
||||
public function select($params = '') |
||||
{ |
||||
$this->queryParams['select'] = str_replace(' ', '', trim($params, " ,\t\r\n")); |
||||
return $this; |
||||
} |
||||
|
||||
/** |
||||
* 分页 |
||||
* @param $number |
||||
* @return $this |
||||
*/ |
||||
public function from($number = 0) |
||||
{ |
||||
$this->queryParams['from'] = $number ? ($number-1)*10 : 0; |
||||
return $this; |
||||
} |
||||
|
||||
/** |
||||
* 页码 |
||||
* @param $number |
||||
* @return $this |
||||
*/ |
||||
public function size($number = 10) |
||||
{ |
||||
$this->queryParams['size'] = $number; |
||||
return $this; |
||||
} |
||||
|
||||
public function equal($params = []) |
||||
{ |
||||
$this->queryParams['equal'][] = $params; |
||||
return $this; |
||||
} |
||||
|
||||
public function in($params = []) |
||||
{ |
||||
$this->queryParams['in'][] = $params; |
||||
return $this; |
||||
} |
||||
|
||||
public function like($params = []) |
||||
{ |
||||
$this->queryParams['like'][] = $params; |
||||
return $this; |
||||
} |
||||
|
||||
public function orlike($params = []) |
||||
{ |
||||
$this->queryParams['orlike'][] = $params; |
||||
return $this; |
||||
} |
||||
|
||||
public function order($params = []) |
||||
{ |
||||
$this->queryParams['order'][] = $params; |
||||
return $this; |
||||
} |
||||
|
||||
/** |
||||
* 根据条件删除文档 |
||||
* @param array $params |
||||
* @return array |
||||
*/ |
||||
|
||||
public function deleteDoc($params = []) |
||||
{ |
||||
return $this->client->deleteByQuery($params); |
||||
} |
||||
|
||||
|
||||
public function existsIndex(String $index_name) { |
||||
$params = [ |
||||
'index' => $index_name |
||||
]; |
||||
return $this->client->indices()->exists($params); |
||||
} |
||||
|
||||
/** |
||||
* 创建索引 |
||||
*/ |
||||
public function createIndex(String $index_name, array $mapping = []): array |
||||
{ |
||||
if ($this->existsIndex($index_name)) { |
||||
throw new Exception('索引已存在'. $index_name); |
||||
} |
||||
|
||||
//只能创建一次 |
||||
$params = [ |
||||
'index' => $index_name, |
||||
'body' => [ |
||||
'settings' => [ |
||||
'number_of_shards' => 5, |
||||
'number_of_replicas' => 1 |
||||
], |
||||
'mappings' => $mapping |
||||
] |
||||
]; |
||||
return $this->client->indices()->create($params); |
||||
} |
||||
|
||||
/** |
||||
* 删除索引 |
||||
*/ |
||||
public function deleteIndex(String $index_name = ''): array{ |
||||
$params = ['index' => $index_name]; |
||||
return $this->client->indices()->delete($params); |
||||
} |
||||
|
||||
/** |
||||
* 根据id删除文档 |
||||
* @param int $id |
||||
* @return array |
||||
*/ |
||||
public function deleteDocById($id = 0) |
||||
{ |
||||
$params = [ |
||||
'index' => $this->index, |
||||
'id' => $id |
||||
]; |
||||
$response = $this->client->delete($params); |
||||
return $response; |
||||
} |
||||
|
||||
/** |
||||
* 组装查询条件 |
||||
* @param array $params |
||||
* @return $this |
||||
*/ |
||||
private function parseQueryParams() |
||||
{ |
||||
$queryParams = [ |
||||
'index' => $this->index, |
||||
'body' => [ |
||||
'query' => [ |
||||
'bool' => [ |
||||
'must' => [], |
||||
'filter' => [] |
||||
] |
||||
] |
||||
], |
||||
'from' => $this->queryParams['from'] ?? 0, |
||||
'size' => $this->queryParams['size'] ?? 10 |
||||
]; |
||||
|
||||
$filter = $must = []; |
||||
if (!empty($this->queryParams['select'])) { |
||||
$queryParams['_source'] = explode(',', $this->queryParams['select']); |
||||
} |
||||
|
||||
if (!empty($this->queryParams['equal'])) { |
||||
foreach ($this->queryParams['equal'] as $key => $row) { |
||||
foreach ($row as $filed => $value) { |
||||
$filter[] = [ |
||||
'term' => [$filed => $value] |
||||
]; |
||||
} |
||||
} |
||||
} |
||||
|
||||
if (!empty($this->queryParams['in'])) { |
||||
foreach ($this->queryParams['in'] as $key => $row) { |
||||
foreach ($row as $filed => $value) { |
||||
$filter[] = [ |
||||
'terms' => [$filed => array_values(array_unique(array_filter($value)))] |
||||
]; |
||||
} |
||||
} |
||||
} |
||||
|
||||
if (!empty($this->queryParams['like'])) { |
||||
foreach ($this->queryParams['like'] as $key => $row) { |
||||
foreach ($row as $filed => $value) { |
||||
/*$must[] = [ |
||||
|
||||
'wildcard' => [$filed => '*'. $value. '*'] |
||||
|
||||
];*/ |
||||
$must[] = [ |
||||
// 'match' => [$filed => $value] |
||||
'match_phrase' => [$filed => $value] |
||||
]; |
||||
} |
||||
} |
||||
|
||||
$queryParams['body']['query']['bool']['must'] = $must; |
||||
|
||||
} |
||||
|
||||
if (!empty($this->queryParams['orlike'])) { |
||||
foreach ($this->queryParams['orlike'] as $key => $row) { |
||||
foreach ($row as $filed => $value) { |
||||
$orlike[] = [ |
||||
'match_phrase' => [$filed => $value] |
||||
]; |
||||
} |
||||
} |
||||
|
||||
$queryParams['body']['query']['bool']['must']['bool']['should'] = $orlike; |
||||
} |
||||
|
||||
if (!empty($this->queryParams['order'])) { |
||||
$queryParams['body']['sort'] = [ |
||||
key($this->queryParams['order']) => [ |
||||
'order' => current($this->queryParams['order']) |
||||
] |
||||
]; |
||||
} |
||||
|
||||
$queryParams['body']['query']['bool']['filter'] = $filter; |
||||
|
||||
$this->queryParams = $queryParams; |
||||
|
||||
return $this; |
||||
|
||||
} |
||||
|
||||
|
||||
/** |
||||
* @param bool $isTotal isTotal=true时, 返回总数 |
||||
* @return array|string |
||||
*/ |
||||
|
||||
public function query($isTotal = false) |
||||
{ |
||||
try { |
||||
$this->parseQueryParams(); |
||||
|
||||
if ($this->debug) { |
||||
return \GuzzleHttp\json_encode($this->queryParams); |
||||
} |
||||
|
||||
if ($isTotal === true) { |
||||
|
||||
unset( |
||||
|
||||
$this->queryParams['from'], |
||||
|
||||
$this->queryParams['size'], |
||||
|
||||
$this->queryParams['_source'] |
||||
|
||||
); |
||||
|
||||
$count = $this->client->count($this->queryParams); |
||||
|
||||
return (int)$count['count']; |
||||
|
||||
} |
||||
|
||||
if (!empty($this->queryParams)) { |
||||
|
||||
$result = $this->client->search($this->queryParams); |
||||
|
||||
if (!empty($result['hits']['hits'])) { |
||||
|
||||
$return = []; |
||||
|
||||
foreach ($result['hits']['hits'] as $row) { |
||||
|
||||
$return[] = $row['_source']; |
||||
|
||||
} |
||||
|
||||
return $return; |
||||
|
||||
} else { |
||||
|
||||
return []; |
||||
|
||||
} |
||||
|
||||
} |
||||
|
||||
} catch (\Exception $e) { |
||||
|
||||
$msg = $e->getMessage(); |
||||
|
||||
$msg = '服务器开小差了~'; |
||||
|
||||
throw new Exception($msg); |
||||
|
||||
} |
||||
} |
||||
|
||||
/** |
||||
* 添加文档 |
||||
* @param $id |
||||
* @param $doc ['id'=>100, 'title'=>'phone'] |
||||
* @param string $index_name |
||||
* @param string $type_name |
||||
*/ |
||||
public function addDoc($id, $doc, string $index_name = 'gyx_ik', string $type_name = '_doc'): array |
||||
{ |
||||
$params = [ |
||||
'index' => $index_name, |
||||
'type' => $type_name, |
||||
'id' => $id, |
||||
'body' => $doc |
||||
]; |
||||
|
||||
return $this->client->index($params); |
||||
} |
||||
|
||||
public function getIndex() |
||||
{ |
||||
return $this->index; |
||||
} |
||||
|
||||
/** |
||||
* 返回ES实例 |
||||
*/ |
||||
|
||||
public static function setEs($index = '') |
||||
{ |
||||
$class = get_called_class(); |
||||
if (!self::$instance || !self::$instance instanceof $class) { |
||||
self::$instance = new static(); |
||||
} |
||||
if ($index) { |
||||
self::$instance->index = $index; |
||||
} |
||||
return self::$instance; |
||||
|
||||
} |
||||
|
||||
protected function settings() |
||||
{ |
||||
return [ |
||||
'number_of_shards' => 1, |
||||
'number_of_replicas' => 0 |
||||
]; |
||||
} |
||||
|
||||
/** |
||||
* 判断文档存在 |
||||
* @param int $id |
||||
* @param string $index_name |
||||
* @param string $type_name |
||||
* @return bool |
||||
*/ |
||||
public function existsDoc(int $id = 1, string $index_name = 'gyx_ik', string $type_name = '_doc'): bool |
||||
{ |
||||
$params = [ |
||||
'index' => $index_name, |
||||
'type' => $type_name, |
||||
'id' => $id |
||||
]; |
||||
|
||||
return $this->client->exists($params); |
||||
|
||||
} |
||||
|
||||
/** |
||||
* 获取文档 |
||||
* @param int $id |
||||
* @param string $index_name |
||||
* @param string $type_name |
||||
* @return array |
||||
*/ |
||||
public function getDoc(int $id = 1, string $index_name = 'gyx_ik', string $type_name = '_doc'): array |
||||
{ |
||||
$params = [ |
||||
'index' => $index_name, |
||||
'type' => $type_name, |
||||
'id' => $id |
||||
]; |
||||
|
||||
return $this->client->get($params); |
||||
} |
||||
|
||||
/** |
||||
* 更新文档 |
||||
* @param int $id |
||||
* @param string $index_name |
||||
* @param string $type_name |
||||
* @param array $body |
||||
* @return array |
||||
*/ |
||||
public function updateDoc(int $id = 1, array $body = [], string $index_name = 'gyx_ik', string $type_name = '_doc'): array |
||||
{ |
||||
// 可以灵活添加新字段，最好不要乱添加 |
||||
$params = [ |
||||
'index' => $index_name, |
||||
'type' => $type_name, |
||||
'id' => $id, |
||||
'body' => $body |
||||
]; |
||||
|
||||
return $this->client->update($params); |
||||
} |
||||
|
||||
|
||||
/** |
||||
* 搜索文档：分页，排序，权重，过滤 |
||||
* @param string $index_name |
||||
* @param string $type_name |
||||
* @param array $body |
||||
* @return array |
||||
*/ |
||||
public function searchDoc(array $body = [], string $index_name = "goods_list", string $type_name = "_doc"): array |
||||
{ |
||||
$params = [ |
||||
'index' => $index_name, |
||||
'type' => $type_name, |
||||
'body' => $body |
||||
]; |
||||
|
||||
return $this->client->search($params); |
||||
} |
||||
|
||||
/** |
||||
|
||||
* @return bool |
||||
|
||||
* @throws Exception |
||||
|
||||
*/ |
||||
|
||||
public function createIndexNew($mapping) |
||||
{ |
||||
try { |
||||
$params = [ |
||||
'index' => $this->index |
||||
]; |
||||
|
||||
$check = $this->indices()->exists($params); |
||||
|
||||
if ($check) { |
||||
throw new Exception('index: ' . $this->index . ' already exists'); |
||||
} |
||||
|
||||
$params = [ |
||||
'index' => $this->index, |
||||
'body' => [ |
||||
'settings' => $this->settings(), |
||||
'mappings' => [ |
||||
'_source' => [ |
||||
'enabled' => true, |
||||
], |
||||
'properties' => $mapping |
||||
] |
||||
] |
||||
]; |
||||
|
||||
$result = $this->indices()->create($params); |
||||
|
||||
return $result['acknowledged'] === true; |
||||
|
||||
} catch (\Exception $e) { |
||||
|
||||
throw new Exception($e->getMessage()); |
||||
|
||||
} |
||||
|
||||
} |
||||
|
||||
/** |
||||
|
||||
* 删除索引 |
||||
|
||||
* |
||||
|
||||
* @return bool |
||||
|
||||
* @throws Missing404Exception |
||||
|
||||
*/ |
||||
|
||||
public function deleteIndexNew() |
||||
{ |
||||
|
||||
try { |
||||
|
||||
$params = [ |
||||
|
||||
'index' => $this->index |
||||
|
||||
]; |
||||
|
||||
$check = $this->indices()->exists($params); |
||||
|
||||
if (!$check) { |
||||
|
||||
return true; |
||||
|
||||
} |
||||
|
||||
$result = $this->indices()->delete([ |
||||
|
||||
'index' => $this->index |
||||
|
||||
]); |
||||
|
||||
return $result['acknowledged'] === true; |
||||
|
||||
} catch (Missing404Exception $e) { |
||||
|
||||
throw new Missing404Exception('no such index ' . $this->index); |
||||
|
||||
} |
||||
|
||||
} |
||||
|
||||
/** |
||||
|
||||
* 批量写入 |
||||
|
||||
* type 1.增加/修改 2.删除 |
||||
|
||||
* $data = [ |
||||
|
||||
* ['id' => 1, 'name' => 'llf', 'age' => 30], |
||||
|
||||
* ['id' => 1, 'name' => 'llf', 'age' => 30], |
||||
|
||||
* ['id' => 1, 'name' => 'llf', 'age' => 30], |
||||
|
||||
* ['id' => 1, 'name' => 'llf', 'age' => 30], |
||||
|
||||
* ]; |
||||
|
||||
* @param array $data |
||||
|
||||
*/ |
||||
|
||||
public function doBulkDocument($type = 1,$data = []) |
||||
|
||||
{ |
||||
|
||||
try { |
||||
|
||||
$params = ['body' => []]; |
||||
|
||||
if($type == 1){ |
||||
|
||||
foreach ($data as $key => $row) { |
||||
|
||||
$params['body'][] = [ |
||||
|
||||
'index' => [ |
||||
|
||||
'_index' => $this->index, |
||||
|
||||
'_id' => $row['info_id'].'-'.$row['info_type'] |
||||
|
||||
] |
||||
|
||||
]; |
||||
|
||||
$params['body'][] = $row; |
||||
|
||||
if (($key+1)%10000 == 0) { |
||||
|
||||
$this->client->bulk($params); |
||||
|
||||
$params = ['body' => []]; |
||||
|
||||
} |
||||
|
||||
} |
||||
|
||||
}else{ |
||||
|
||||
foreach ($data as $key => $row) { |
||||
|
||||
$params['body'][] = [ |
||||
|
||||
'delete' => [ |
||||
|
||||
'_index' => $this->index, |
||||
|
||||
'_id' => $row['info_id'].'-'.$row['info_type'] |
||||
|
||||
] |
||||
|
||||
]; |
||||
|
||||
} |
||||
|
||||
} |
||||
|
||||
if (!empty($params['body'])) { |
||||
|
||||
$this->client->bulk($params); |
||||
|
||||
return true; |
||||
|
||||
} |
||||
|
||||
} catch (\Exception $e) { |
||||
|
||||
throw new Exception($e->getMessage()); |
||||
|
||||
} |
||||
|
||||
} |
||||
|
||||
/** |
||||
|
||||
* @return array @todo |
||||
|
||||
*/ |
||||
|
||||
public function updateIndex() |
||||
|
||||
{ |
||||
|
||||
$putParams = [ |
||||
|
||||
'index' => $this->index, |
||||
|
||||
//'type' => '_doc', |
||||
|
||||
'body' => [ |
||||
|
||||
'properties' => $this->mappings() |
||||
|
||||
] |
||||
|
||||
]; |
||||
|
||||
return $this->indices()->putMapping($putParams); |
||||
|
||||
} |
||||
|
||||
/** |
||||
|
||||
* 方便调试, 直接返回拼接的query |
||||
|
||||
* @return $this |
||||
|
||||
*/ |
||||
|
||||
public function setDebug() |
||||
|
||||
{ |
||||
|
||||
$this->debug = true; |
||||
|
||||
return $this; |
||||
|
||||
} |
||||
|
||||
private function indices() |
||||
|
||||
{ |
||||
|
||||
return $this->client->indices(); |
||||
|
||||
} |
||||
|
||||
public function analyze($text = '') |
||||
|
||||
{ |
||||
|
||||
$params = [ |
||||
|
||||
'index' => $this->index, |
||||
|
||||
'body' => [ |
||||
|
||||
'analyzer' => 'ik_smart', |
||||
|
||||
'text' => $text |
||||
|
||||
] |
||||
|
||||
]; |
||||
|
||||
return $this->indices()->analyze($params); |
||||
|
||||
} |
||||
|
||||
public function update($id = 0, $updateParams = []) |
||||
|
||||
{ |
||||
|
||||
$params = [ |
||||
|
||||
'index' => $this->index, |
||||
|
||||
'id' => $id, |
||||
|
||||
'body' => [ |
||||
|
||||
'doc' => $updateParams |
||||
|
||||
] |
||||
|
||||
]; |
||||
|
||||
return $this->client->update($params); |
||||
} |
||||
} |
||||
@ -0,0 +1,163 @@ |
||||
<?php |
||||
|
||||
namespace app\common\service; |
||||
|
||||
use app\common\library\elasticsearch\Client; |
||||
|
||||
class GoodsEs |
||||
{ |
||||
private Client $esService; |
||||
|
||||
private $index_name = 'goods_list'; |
||||
|
||||
public function __construct() |
||||
{ |
||||
$this->esService = Client::setEs('goods_List'); |
||||
} |
||||
|
||||
/** |
||||
* 查询商品列表 |
||||
* @param $params |
||||
* @return |
||||
*/ |
||||
public function list($params) |
||||
{ |
||||
$page = 1; |
||||
$limit = 10; |
||||
$body = [ |
||||
'query' => [ |
||||
'match_all' => [] |
||||
], |
||||
'from' => ($page - 1) * $limit, |
||||
'size' => $limit, |
||||
'sort' => [ |
||||
'id' => [ |
||||
'order' => 'desc' |
||||
] |
||||
] |
||||
]; |
||||
|
||||
return $this->esService |
||||
->equal(['title' => 1]) |
||||
->from(0) |
||||
->size(10) |
||||
->order(['id' => 'desc']) |
||||
->query($body); |
||||
} |
||||
|
||||
|
||||
|
||||
|
||||
/** |
||||
* 更新商品 |
||||
*/ |
||||
public function update($goods_id) |
||||
{ |
||||
$goods_id = 1; |
||||
$doc = [ |
||||
'id' => $goods_id, |
||||
'video_title' => '少爷的甜蜜良药', |
||||
'director' => '吴宇森', |
||||
'intro' => '吴宇森导演的《少爷的甜蜜良药》是吴宇森导演的经典作品，讲述了一个boyfriend和girlfriend的故事，boyfriend因为工作原因，被拒了girlfriend的offer，然后boyfriend和girlfriend一起去一个地方，然后boyfriend和girlfriend', |
||||
'cover' => 'https://oss-duanju-file.luochen.com/cover/202404/62249c6a-5f57-45cf-90ac-be6de5890ce0.jpg?x-oss-process=image/resize,m_fixed,h_400,w_360', |
||||
'episode_count' => '12', |
||||
'wechat_vid' => 'wx_vid_1', |
||||
'duration' => '01:02:03', |
||||
'service_types' => '2,3', |
||||
]; |
||||
$res = $this->esService->updateDoc($goods_id, $doc); |
||||
var_dump($res); |
||||
} |
||||
|
||||
/** |
||||
* 查询商品详情 |
||||
*/ |
||||
public function detail($goods_id) |
||||
{ |
||||
$goods_id = 1; |
||||
$res = $this->esService->getDoc($goods_id); |
||||
var_dump($res); |
||||
} |
||||
|
||||
|
||||
/** |
||||
* 创建商品 |
||||
* @return |
||||
*/ |
||||
public function create($goods_id) |
||||
{ |
||||
$goods_id = 1; |
||||
$doc = [ |
||||
'id' => $goods_id, |
||||
'video_title' => '少爷的甜蜜良药', |
||||
'director' => '吴宇森', |
||||
'intro' => '吴宇森导演的《少爷的甜蜜良药》是吴宇森导演的经典作品，讲述了一个boyfriend和girlfriend的故事，boyfriend因为工作原因，被拒了girlfriend的offer，然后boyfriend和girlfriend一起去一个地方，然后boyfriend和girlfriend', |
||||
'cover' => 'https://oss-duanju-file.luochen.com/cover/202404/62249c6a-5f57-45cf-90ac-be6de5890ce0.jpg?x-oss-process=image/resize,m_fixed,h_400,w_360', |
||||
'episode_count' => '12', |
||||
'wechat_vid' => 'wx_vid_1', |
||||
'duration' => '01:02:03', |
||||
'service_types' => '2,3', |
||||
]; |
||||
$res = $this->esService->addDoc($goods_id, $doc); |
||||
var_dump($res); |
||||
} |
||||
|
||||
/** |
||||
* 删除商品 |
||||
*/ |
||||
public function delete($goods_id) |
||||
{ |
||||
$res = $this->esService->deleteDoc($goods_id); |
||||
var_dump($res); |
||||
} |
||||
|
||||
|
||||
|
||||
/** |
||||
* 创建商品Index |
||||
* @return void |
||||
* @throws Exception |
||||
*/ |
||||
function createGoodsIndex() |
||||
{ |
||||
$mapping = [ |
||||
'properties' => [ |
||||
'goods_id' => [ |
||||
'type' => 'integer' |
||||
], |
||||
'goods_type' => [ |
||||
'type' => 'keyword' |
||||
], |
||||
'director' => [ |
||||
'type' => 'text', |
||||
"analyzer" => "ik_smart" |
||||
], |
||||
'intro' => [ |
||||
'type' => 'text', |
||||
"analyzer" => "ik_smart" |
||||
], |
||||
'cover' => [ |
||||
'type' => 'keyword' |
||||
], |
||||
'episode_count' => [ |
||||
'type' => 'keyword' |
||||
], |
||||
'wechat_vid' => [ |
||||
'type' => 'keyword' |
||||
], |
||||
'duration' => [ |
||||
'type' => 'keyword' |
||||
], |
||||
'service_types' => [ |
||||
'type' => 'keyword' |
||||
], |
||||
] |
||||
]; |
||||
|
||||
$res = $this->esService->createIndex($this->index_name, $mapping); |
||||
var_dump($res); |
||||
} |
||||
|
||||
|
||||
|
||||
} |
||||
@ -0,0 +1,49 @@ |
||||
<?php |
||||
// +---------------------------------------------------------------------- |
||||
// | 萤火商城系统 [ 致力于通过产品和服务，帮助商家高效化开拓市场 ] |
||||
// +---------------------------------------------------------------------- |
||||
// | Copyright (c) 2017~2023 https://www.yiovo.com All rights reserved. |
||||
// +---------------------------------------------------------------------- |
||||
// | Licensed 这不是一个自由软件，不允许对程序代码以任何形式任何目的的再发行 |
||||
// +---------------------------------------------------------------------- |
||||
// | Author: 萤火科技 <admin@yiovo.com> |
||||
// +---------------------------------------------------------------------- |
||||
declare (strict_types=1); |
||||
|
||||
namespace app\job\controller\goods; |
||||
|
||||
use app\job\service\goods\GoodsAddPrice as GoodsAddPriceService; |
||||
use cores\BaseJob; |
||||
use cores\traits\QueueTrait; |
||||
use cores\exception\BaseException; |
||||
use think\db\exception\DataNotFoundException; |
||||
use think\db\exception\DbException; |
||||
use think\db\exception\ModelNotFoundException; |
||||
|
||||
/** |
||||
* 队列任务：商品批量导入 |
||||
* Class Import |
||||
* @package app\job\controller |
||||
*/ |
||||
class GoodsAddPrice extends BaseJob |
||||
{ |
||||
use QueueTrait; |
||||
|
||||
/** |
||||
* 消费队列任务：商品导入 |
||||
* @param array $data 参数 [index队列顺序；totalCount商品总数量；list商品列表；storeId商城ID] |
||||
* @return bool 返回结果 |
||||
* @throws BaseException |
||||
* @throws DataNotFoundException |
||||
* @throws DbException |
||||
* @throws ModelNotFoundException |
||||
*/ |
||||
public function handle(array $data): bool |
||||
{ |
||||
$time = date('H:i:s'); |
||||
echo "\n ---- GoodsAddPrice ---- {$time} ---- \n"; |
||||
|
||||
$service = new GoodsAddPriceService; |
||||
return $service->batch($data['list'], $data['rate']); |
||||
} |
||||
} |
||||
@ -0,0 +1,99 @@ |
||||
<?php |
||||
// +---------------------------------------------------------------------- |
||||
// | 萤火商城系统 [ 致力于通过产品和服务，帮助商家高效化开拓市场 ] |
||||
// +---------------------------------------------------------------------- |
||||
// | Copyright (c) 2017~2023 https://www.yiovo.com All rights reserved. |
||||
// +---------------------------------------------------------------------- |
||||
// | Licensed 这不是一个自由软件，不允许对程序代码以任何形式任何目的的再发行 |
||||
// +---------------------------------------------------------------------- |
||||
// | Author: 萤火科技 <admin@yiovo.com> |
||||
// +---------------------------------------------------------------------- |
||||
declare (strict_types=1); |
||||
|
||||
namespace app\job\service\goods; |
||||
|
||||
use app\common\library\helper; |
||||
use app\common\service\BaseService; |
||||
use app\common\model\Goods as GoodsModel; |
||||
use app\common\model\GoodsSku; |
||||
use app\store\model\GoodsCategoryRel; |
||||
use cores\exception\BaseException; |
||||
use think\facade\Log; |
||||
use app\common\model\Channel; |
||||
use app\common\model\Region; |
||||
/** |
||||
* 服务类：商品批量导入 |
||||
* Class Import |
||||
* @package app\job\service\goods |
||||
*/ |
||||
class GoodsAddPrice extends BaseService |
||||
{ |
||||
/** |
||||
* 批量导入商品 |
||||
* @param array $list |
||||
* @param int $recordId |
||||
* @param int $storeId |
||||
* @return bool |
||||
* @throws BaseException |
||||
* @throws \think\db\exception\DataNotFoundException |
||||
* @throws \think\db\exception\DbException |
||||
* @throws \think\db\exception\ModelNotFoundException |
||||
*/ |
||||
public function batch(array $goods, int $rate): bool |
||||
{ |
||||
// ini_set('memory_limit', '1024M'); |
||||
// set_time_limit(0); |
||||
// $goods = GoodsModel::alias('g') |
||||
// ->join('goods_category_rel c', 'g.goods_id = c.goods_id') |
||||
// ->where('c.store_id',0) |
||||
// ->where('g.is_delete',0) |
||||
// ->whereIn('c.category_id', $categoryIds) |
||||
// ->whereIn('g.channel',$channels) |
||||
// ->order("g.goods_id asc") |
||||
// ->select() |
||||
// ->toArray(); |
||||
if (!$goods) { |
||||
return true; |
||||
} |
||||
//更新总后台当前商品的价格 |
||||
GoodsModel::whereIn('goods_id', array_column($goods, "goods_id"))->update(['markup_rate' => $rate, 'update_time' => time()]); |
||||
foreach ($goods as $key => $value) { |
||||
//更新origin_goods_id为当前商品id的价格 |
||||
$goods_list = GoodsModel::where('origin_goods_id', $value['goods_id']) |
||||
->where('is_delete', 0) |
||||
->field(['goods_id','cost_price_min','goods_price_min','markup_rate']) |
||||
->select() |
||||
->toArray(); |
||||
|
||||
if (!$goods_list) { |
||||
continue; |
||||
} |
||||
$item = $goods_list[0]; |
||||
// if ($item['markup_rate'] > 0) { |
||||
// $item['cost_price_min'] = round($item['cost_price_min'] * (1 - ($rate / 100)), 0); |
||||
// } |
||||
$item['cost_price_min'] = $value['cost_price_min'];//设置原始数据的成本价 |
||||
$cost_price = round($item['cost_price_min'] / (1 - ($rate / 100)), 0); |
||||
$profit = (float)$item['goods_price_min'] - (float)$cost_price; |
||||
$profit_rate = (float)$item['goods_price_min'] > 0 ? bcmul((string)($profit / (float)$item['goods_price_min']) , (string)100, 2) : 0.00; |
||||
$goodsData = [ |
||||
'cost_price_min' => $cost_price, |
||||
'profit_rate' => $profit_rate, |
||||
'profit' => $profit, |
||||
'markup_rate' => $rate, |
||||
'update_time' => time() |
||||
]; |
||||
GoodsModel::whereIn('goods_id', array_column($goods_list, "goods_id"))->update($goodsData); |
||||
$goodsSkuData = [ |
||||
'cost_price' => $cost_price, |
||||
'update_time' => time() |
||||
]; |
||||
GoodsSku::whereIn('goods_id', array_column($goods_list, "goods_id"))->update($goodsSkuData); |
||||
|
||||
} |
||||
|
||||
return true; |
||||
} |
||||
|
||||
|
||||
} |
||||
Loading…
Reference in new issue