server/src/app/Http/Controllers/Api/GeoStatsController.php
author ymh <ymh.work@gmail.com>
Thu, 20 Oct 2016 19:14:37 +0200
changeset 378 5b47eab083f3
parent 377 52169c718513
child 406 cf0f23803a53
permissions -rw-r--r--
implement filters on stats controller, put all filter logic in CorpusFilterManager

<?php

namespace CorpusParole\Http\Controllers\Api;

use Illuminate\Http\Request;

use CorpusParole\Http\Controllers\Controller;
use CorpusParole\Libraries\Filters\CorpusFilterManager;

use Es;
use Log;

class GeoStatsController extends Controller
{
    /**
     * Display the specified resource.
     *
     * @return \Illuminate\Http\Response
     */
    public function index(Request $request)
    {
        $area = $request->input('area');

        $filterManager = new CorpusFilterManager();
        $filters = $filterManager->prepareFilters($request);
        unset($filters['location']);
        $qFilterParts = $filterManager->buildESFilters($filters);
        if(is_null($qFilterParts)) {
            $qFilterParts = [];
        }

        if(!is_null($area) && $area !== config('corpusparole.geonames_earth_geonamesid')) {
            $qFilterParts[] = [
                'term' => [
                    "geonames_hierarchy" => $area
                ]
            ];
        }

        $query = $filterManager->buildQuery($qFilterParts);

        $queryES = [
            'index' => env('ELASTICSEARCH_INDEX'),
            'body' => [
                "size" => 0,
                "query" => $query,
                "aggs" => [
                    "geos" => [
                        "terms" => [
                            "size" => 0,
                            "field" => "geonames_hierarchy"
                        ]
                    ]
                ]
            ]
        ];
        $esRes = Es::search($queryES);

        $geosats = [];

        foreach($esRes['aggregations']['geos']['buckets'] as $bucket) {
            $geosats[(string)($bucket['key'])] = $bucket['doc_count'];
        }

        return response()->json(['geostats' => $geosats ]);
    }
}