在它们各自的路径中创建以下帮助程序类：
App Traits ElasticSearchEventTrait.php
<?phpNamespace AppTraits;trait ElasticSearchEventTrait { public $esRemoveDefault = array('created_at','updated_at','deleted_at'); public static function boot() { parent::boot(); static::bootElasticSearchEvent(); } public static function bootElasticSearchEvent() { static::created(function ($model) { if(isset($model->esEnabled) && $model->esEnabled === true) { $model->esCreate(); } }); static::updated(function ($model) { if(isset($model->esEnabled) && $model->esEnabled === true) { $model->esUpdate(); } }); static::deleted(function ($model) { if(isset($model->esEnabled) && $model->esEnabled === true) { $model->esUpdate(); } }); } private function esCreate() { //esContext is false for polymorphic relations with no elasticsearch indexing if(isset($this->esMain) && $this->esMain === true && $this->esContext !== false) { Queue::push('ElasticSearchHelper@indexTask',array('id'=>$this->esGetId(),'class'=>get_class($this),'context'=>$this->esGetContext(),'info-context'=>$this->esGetInfoContext(),'excludes'=>$this->esGetRemove())); } else { $this->esUpdate(); } } private function esUpdate() { //esContext is false for polymorphic relations with no elasticsearch indexing if($this->esContext !== false) { Queue::push('ElasticSearchHelper@updateTask',array('id'=>$this->esGetId(),'class'=>get_class($this),'context'=>$this->esGetContext(),'info-context'=>$this->esGetInfoContext(),'excludes'=>$this->esGetRemove())); } } public function esGetId() { if(isset($this->esId)) { return $this->esId; } else { return $this->id; } } public function esGetInfoContext() { if(isset($this->esInfoContext)) { return $this->esInfoContext; } else { throw new RuntimeException("esInfoContext attribute or esGetInfoContext() is not set in class '".get_class($this)."'"); } } public function esGetContext() { if(isset($this->esContext)) { return $this->esContext; } else { throw new RuntimeException("esContext attribute or esGetContext() method must be set in class '".get_class($this)."'"); } } public function esGetRemove() { if(isset($this->esRemove)) { return array_unique(array_merge($this->esRemoveDefault,$this->esRemove)); } else { return $this->esRemoveDefault; } } public function newCollection(array $models = Array()) { return new CoreCollection($models); } public function asEsDateTime($value) { // If this value is an integer, we will assume it is a UNIX timestamp's value // and format a Carbon object from this timestamp. This allows flexibility // when defining your date fields as they might be UNIX timestamps here. if (is_numeric($value)) { return Carbon::createFromTimestamp($value); } // If the value is in simply year, month, day format, we will instantiate the // Carbon instances from that format. Again, this provides for simple date // fields on the database, while still supporting Carbonized conversion. elseif (preg_match('/^(d{4})-(d{2})-(d{2})$/', $value)) { return Carbon::createFromFormat('Y-m-d', $value)->startOfDay(); } // Finally, we will just assume this date is in the format used by default on // the database connection and use that format to create the Carbon object // that is returned back out to the developers after we convert it here. elseif ( ! $value instanceof DateTime) { $format = $this->getEsDateFormat(); return Carbon::createFromFormat($format, $value); } return Carbon::instance($value); } private function getEsDateFormat() { return $this->getConnection()->getQueryGrammar()->getDateFormat(); } public function getEsSaveFormat() { $obj = clone $this; //Go through ES Accessors ElasticSearchHelper::esAccessor($obj); $dates = $this->getDates(); //Convert to array, then change Date to appropriate Elasticsearch format. //Why? Because eloquent's date accessors is playing me. $dataArray = $obj->attributesToArray(); //Remove all Excludes foreach($this->esGetRemove() as $ex) { if(array_key_exists($ex,$dataArray)) { unset($dataArray[$ex]); } } if(!empty($dates)) { foreach($dates as $d) { if(isset($dataArray[$d]) && $dataArray[$d] !== "" ) { //Trigger Eloquent Getter which will provide a Carbon instance $dataArray[$d] = $this->{$d}->toIso8601String(); } } } return $dataArray; }}App Services ElasticServiceHelper.php
<?phpNamespace AppServices;class ElasticSearchHelper { public function indexTask($job,$data) { if(Config::get('website.elasticsearch') === true) { if(isset($data['context'])) { $this->indexEs($data); } else { Log::error('ElasticSearchHelper: No context set for the following dataset: '.json_enpre($data)); } } $job->delete(); } public function updateTask($job,$data) { if(Config::get('website.elasticsearch') === true) { if(isset($data['context'])) { $this->updateEs($data); } else { Log::error('ElasticSearchHelper: No context set for the following dataset: '.json_enpre($data)); } } $job->delete(); } public function indexEs($data) { $params = array(); $params['index'] = App::environment(); $params['type'] = $data['context']; $model = new $data['class']; $form = $model::find($data['id']); if($form) { $params['id'] = $form->id; if($form->timestamps) { $params['timestamp'] = $form->updated_at->toIso8601String(); } $params['body'][$data['context']] = $this->saveFormat($form); Es::index($params); } } public function updateEs($data) { $params = array(); $params['index'] = App::environment(); $params['type'] = $data['context']; $model = new $data['class']; $form = $model::withTrashed()->find($data['id']); if(count($form)) { if($data['info-context'] === $data['context']) { $params['id'] = $data['id']; $params['body']['doc'][$data['info-context']] = $this->saveFormat($form); } else { //Form is child, we get parent $parent = $form->esGetParent(); if(count($parent)) { //Id is always that of parent $params['id'] = $parent->id; //fetch all children, given that we cannot save per children basis $children = $parent->{$data['info-context']}()->get(); if(count($children)) { //Get data in a format that can be saved by Elastic Search $params['body']['doc'][$data['info-context']] = $this->saveFormat($children); } else { //Empty it is $params['body']['doc'][$data['info-context']] = array(); } } else { Log::error("Parent not found for {$data['context']} - {$data['class']}, Id: {$data['id']}"); return false; } } //Check if Parent Exists try { $result = Es::get([ 'id' => $params['id'], 'index' => $params['index'], 'type' => $data['context'] ]); } catch (Exception $ex) { if($ex instanceof ElasticsearchCommonExceptionsMissing404Exception || $ex instanceof GuzzleHttpExceptionClientErrorResponseException) { //if not, we set it if (isset($parent) && $parent) { $this->indexEs([ 'context' => $data['context'], 'class' => get_class($parent), 'id' => $parent->id, ]); } else { Log::error('Unexpected error in updating elasticsearch records, parent not set with message: '.$ex->getMessage()); return false; } } else { Log::error('Unexpected error in updating elasticsearch records: '.$ex->getMessage()); return false; } } Es::update($params); } } public function esAccessor(&$object) { if(is_object($object)) { $attributes = $object->getAttributes(); foreach($attributes as $name => $value) { $esMutator = 'get' . studly_case($name) . 'EsAttribute'; if (method_exists($object, $esMutator)) { $object->{$name} = $object->$esMutator($object->{$name}); } } } else { throw New RuntimeException("Expected type object"); } } public function saveFormat($object) { if($object instanceof IlluminateDatabaseEloquentModel) { return $object->getEsSaveFormat(); } else { return array_map(function($value) { return $value->getEsSaveFormat(); }, $object->all()); } }}以上帮助程序类中的一些陷阱：
默认的ElasticSearch索引设置为应用程序环境的名称
这些
..task()功能适用于旧的laravel 4.2队列格式。我还没有将它们移植到laravel5.x。这同样适用于
Queue::push命令。
例
ElasticSearch映射：
[ 'automobile' => [ "dynamic" => "strict", 'properties' => [ 'automobile' => [ 'properties' => [ 'id' => [ 'type' => 'long', 'index' => 'not_analyzed' ], 'manufacturer_name' => [ 'type' => 'string', ], 'manufactured_on' => [ 'type' => 'date' ] ] ], 'car' => [ 'properties' => [ 'id' => [ 'type' => 'long', 'index' => 'not_analyzed' ], 'name' => [ 'type' => 'string', ], 'model_id' => [ 'type' => 'string' ] ] ], "car-model" => [ 'properties' => [ 'id' => [ 'type' => 'long', 'index' => 'not_analyzed' ], 'description' => [ 'type' => 'string', ], 'name' => [ 'type' => 'string' ] ] ] ] ]]
- 顶级文档称为“汽车”。在它的下面，您有“汽车”，“汽车”和“汽车模型”。将“汽车”和“汽车模型”视为与汽车的关系。它们被称为Elasticsearch的子文档。（请参阅：https
- //www.elastic.co/guide/zh-
CN/elasticsearch/guide/current/document.html）
型号：App Models Car.php
namespace AppModels;class Car extends Eloquent { use IlluminateDatabaseEloquentSoftDeletingTrait; use AppTraitsElasticSearchEventTrait; protected $table = 'car'; protected $fillable = [ 'name', 'serie', 'model_id', 'automobile_id' ]; protected $dates = [ 'deleted_at' ]; //Indexing Enabled public $esEnabled = true; //Context for Indexing - Top Level name in the mapping public $esContext = "automobile"; //Info Context - Secondary level name in the mapping. public $esInfoContext = "car"; //The following fields will not be saved in elasticsearch. public $esRemove = ['automobile_id']; //Fetches parent relation of car, so that we can retrieve its id for saving in the appropriate elasticsearch record public function esGetParent() { return $this->automobile; } public static function boot() { parent:: boot(); //Attach events to model on start static::bootElasticSearchEvent(); } public function getModelIdEsAttribute($model_id) { //Fetch model from table $model = AppModelsCarModel::find($model_id); if($model) { //Return name of model if found return $model->name; } else { return ''; } } public function automobile() { return $this->belongsTo('AppModelsAutomobile','automobile_id'); }}搜索查询示例：
public function getAll($search){ $params = array(); $params['index'] = App::environment(); //Declare your mapping names in the array which you wish to search on. $params['type'] = array('automobile'); //Exact match is favored instead of fuzzy ones $params['body']['query']['bool']['should'][0]['match']['name']['query'] = $search; $params['body']['query']['bool']['should'][0]['match']['name']['operator'] = "and"; $params['body']['query']['bool']['should'][0]['match']['name']['boost'] = 2; $params['body']['query']['bool']['should'][1]['fuzzy_like_this']['like_text'] = $search; $params['body']['query']['bool']['should'][1]['fuzzy_like_this']['fuzziness'] = 0.5; $params['body']['query']['bool']['should'][1]['fuzzy_like_this']['prefix_length'] = 2; $params['body']['query']['bool']['minimum_should_match'] = 1; //Highlight matches $params['body']['highlight']['fields']['*'] = new stdClass(); $params['body']['highlight']['pre_tags'] = array('<b>'); $params['body']['highlight']['post_tags'] = array('</b>'); //Exclude laravel timestamps $params['body']['_source']['exclude'] = array( "*.created_at","*.updated_at","*.deleted_at"); $from_offset = 0; $result = array(); //Loop through all the search results do { try { $params['body']['from'] = $from_offset; $params['body']['size'] = 5; $queryResponse = Es::search($params); //Custom function to process the result //Since we will receive a bunch of arrays, we need to reformat the data and display it properly. $result = $this->processSearchResult($queryResponse); $from_offset+= 5; } catch (Exception $e) { Log::error($e->getMessage()); return Response::make("An error occured with the search server.",500); } } while (count($result) === 0 && $queryResponse['hits']['total'] > 0); echo json_enpre($result);} private function processSearchResult(array $queryResponse){ $result = array(); //Check if we have results in the array if($queryResponse['hits']['total'] > 0 && $queryResponse['timed_out'] === false) { //Loop through each result foreach($queryResponse['hits']['hits'] as $line) { //Elasticsearch will highlight the relevant sections in your query in an array. The below creates a readable format with · as delimiter. $highlight = ""; if(isset($line['highlight'])) { foreach($line['highlight'] as $k=>$v) { foreach($v as $val) { $highlight[] = str_replace("_"," ",implode(" - ",explode(".",$k)))." : ".$val; } } $highlight = implode(" · ",$highlight); } //Check the mapping type switch($line['_type']) { case "automobile": $result[] = array('icon'=>'fa-automobile', 'title'=> 'Automobile', 'id' => $line['_id'], //name to be displayed on my search result page 'value'=>$line['_source'][$line['_type']]['name']." (Code: ".$line['_id'].")", //Using a helper to generate the url. Build your own class. 'url'=>AppHelpersURLGenerator::generate($line['_type'],$line['_id']), //And the highlights as formatted above. 'highlight'=>$highlight); break; } } } return $result;}欢迎分享，转载请注明来源：内存溢出
微信扫一扫
支付宝扫一扫
评论列表（0条）