封装：
?安装插件：
在您的composer.json文件中包含elasticsearch-php
{
"require": {
"elasticsearch/elasticsearch": "~7.0"
}
}
comoposer require elasticsearch/elasticsearch
composer updatecomposer require guzzlehttp/guzzle<?php
namespace App\lib;
use GuzzleHttp\Client;
class Gao
{
public static function gaoDe($address,$province){
// 发起HTTP请求
// 得到请求地址
$api = config('gaode.geocode');
$url = sprintf($api, $address, $province);
// 声明请求类，指定过期时间
$client = new Client(['timeout' => 5]);
// 发起请求
$response = $client->get($url);
$body = (string)$response->getBody();
$arr = json_decode($body, true);
// dd($arr);
// 找到对应经纬度，存数据表
if (count($arr['geocodes']) > 0) {
$locationArr = explode(',', $arr['geocodes'][0]['location']);
return $locationArr;
}
}
}<?php
namespace App\lib;
use Elasticsearch\ClientBuilder;
class Es
{
//ES客户端链接
private $client;
/**
* 构造函数
* MyElasticsearch constructor.
*/
public function __construct()
{
$params = array(
'127.0.0.1:9200'
);
$this->client = ClientBuilder::create()->setHosts($params)->build();
}
/**
* 判断索引是否存在
* @param string $index_name
* @return bool|mixed|string
*/
public function exists_index($index_name = 'test_ik')
{
$params = [
'index' => $index_name
];
try {
return $this->client->indices()->exists($params);
} catch (\Elasticsearch\Common\Exceptions\BadRequest400Exception $e) {
$msg = $e->getMessage();
$msg = json_decode($msg,true);
return $msg;
}
}
/**
* 创建索引
* @param string $index_name
* @return array|mixed|string
*/
public function create_index($index_name = 'test_ik') { // 只能创建一次
$params = [
'index' => $index_name,
'body' => [
'settings' => [
'number_of_shards' => 5,
'number_of_replicas' => 0
]
]
];
try {
return $this->client->indices()->create($params);
} catch (\Elasticsearch\Common\Exceptions\BadRequest400Exception $e) {
$msg = $e->getMessage();
$msg = json_decode($msg,true);
return $msg;
}
}
/**
* 删除索引
* @param string $index_name
* @return array
*/
public function delete_index($index_name = 'test_ik') {
$params = ['index' => $index_name];
$response = $this->client->indices()->delete($params);
return $response;
}
/**
* 添加文档
* @param $id
* @param $doc ['id'=>100, 'title'=>'phone']
* @param string $index_name
* @param string $type_name
* @return array
*/
public function add_doc($id,$doc,$index_name = 'test_ik',$type_name = 'goods') {
$params = [
'index' => $index_name,
'type' => $type_name,
'id' => $id,
'body' => $doc
];
$response = $this->client->index($params);
return $response;
}
/**
* 判断文档存在
* @param int $id
* @param string $index_name
* @param string $type_name
* @return array|bool
*/
public function exists_doc($id = 1,$index_name = 'test_ik',$type_name = 'goods') {
$params = [
'index' => $index_name,
'type' => $type_name,
'id' => $id
];
$response = $this->client->exists($params);
return $response;
}
/**
* 获取文档
* @param int $id
* @param string $index_name
* @param string $type_name
* @return array
*/
public function get_doc($id = 1,$index_name = 'test_ik',$type_name = 'goods') {
$params = [
'index' => $index_name,
'type' => $type_name,
'id' => $id
];
$response = $this->client->get($params);
return $response;
}
/**
* 更新文档
* @param int $id
* @param string $index_name
* @param string $type_name
* @param array $body ['doc' => ['title' => '苹果手机iPhoneX']]
* @return array
*/
public function update_doc($id = 1,$index_name = 'test_ik',$type_name = 'goods', $body=[]) {
// 可以灵活添加新字段,最好不要乱添加
$params = [
'index' => $index_name,
'type' => $type_name,
'id' => $id,
'body' => $body
];
$response = $this->client->update($params);
return $response;
}
/**
* 删除文档
* @param int $id
* @param string $index_name
* @param string $type_name
* @return array
*/
public function delete_doc($id = 1,$index_name = 'test_ik',$type_name = 'goods') {
$params = [
'index' => $index_name,
'type' => $type_name,
'id' => $id
];
$response = $this->client->delete($params);
return $response;
}
/**
* 搜索文档 (分页，排序，权重，过滤)
* @param string $index_name
* @param string $type_name
* @param array $body
* $body = [
'query' => [
'bool' => [
'should' => [
[
'match' => [
'cate_name' => [
'query' => $keywords,
'boost' => 4, // 权重大
]
]
],
[
'match' => [
'goods_name' => [
'query' => $keywords,
'boost' => 3,
]
]
],
[
'match' => [
'goods_introduce' => [
'query' => $keywords,
'boost' => 2,
]
]
]
],
],
],
'sort' => ['id'=>['order'=>'desc']],
'from' => $from,
'size' => $size
];
* @return array
*/
public function search_doc($index_name = "test_ik",$type_name = "goods",$body=[]) {
$params = [
'index' => $index_name,
'type' => $type_name,
'body' => $body
];
$results = $this->client->search($params);
return $results;
}
}
config中经纬度转化：
?
<?php
return[
// 把地址转化为经纬度
'geocode'=>'https://restapi.amap.com/v3/geocode/geo?key=f814bbfcb1fb9feb27a0887fbc06ad77&address=%s&city=%s&output=json'
];
控制器调用：
?
?
public function fangAdd(CheckFang $request)
{
$data = $request->input();
unset($data['file']);
$data['fang_direction']=$data['fang1'];
$data['fang_rent_class']=$data['fang2'];
$data['fang_area']=$data['fang4'];
$data['fang_rent_range']=$data['fang5'];
$data['fang_rent_type']=$data['fang6'];
$data['fang_status']=$data['fang7'];
$data['fang_group']=$data['fang8'];
$fang_config=$data['fang_config'];
// 配套设施处理为字符串
$data['fang_config']=implode(',',$fang_config);
try {
$res = Fang::fangAdd($data);
$address=$res->fang_addr;
$id = $res->fang_province;
// 根据省id查询省
$fang_province = City::selectProvince($id);
$province=$fang_province->name;
// 引入高德封装的类
$data=Gao::gaoDe($address,$province);
$res->update([
'longitude' => $data[0],
'latitude' => $data[1]
]);
$id=$res->id;
$result=$res->toArray();
$es=new Es();
$es->add_doc($id,$result,'fang_ik','fang');
return redirect('fang/fangList');
} catch (Exception $e) {
throw new Exception('服务器异常');
}
}kibana查看：
GET /fang_ik/_search