foothing/laravel-simple-pageviews

<?php namespace Foothing\Laravel\Visits\Repositories;

use Carbon\Carbon;
use Foothing\Laravel\Visits\Models\Visit;
use Foothing\Repository\Eloquent\EloquentRepository;

class VisitRepository extends EloquentRepository {

    public function __construct(Visit $visit) {
        parent::__construct($visit);
    }

    public function update($visit) {
        $unique = [
            'session' => $visit->session,
            'ip' => $visit->ip,
            'url' => $visit->url,
            'date' => $visit->date
        ];

        $values = [
            'count' => \DB::raw('count+1')
        ];

        // Not using $this->model here, since we need
        // to operate on the buffer table.
        return $visit->updateOrCreate($unique, $values);
    }

    /**
     * Applies where clause on date column.
     *
     * @param Carbon $start
     * @param Carbon $end
     * @param string $url
     *
     * @return mixed
     */
    public function where(Carbon $start, Carbon $end = null, $url = null) {
        if ($end) {
            $query = $this->model->whereBetween("date", [$start->format('Y-m-d'), $end->format('Y-m-d')]);
        } else {
            $query = $this->model->where("date", $start->format('Y-m-d'));
        }

        if ($url) {
            $query = $query->whereUrl($url);
        }

        return $query;
    }

    /**
     * Return the list of urls with best performance, ordered by hits.
     *
     * @param Carbon $start
     * @param Carbon|null $end
     * @param int  $limit
     *
     * @return mixed
     */
    public function aggregate(Carbon $start, Carbon $end = null, $limit = 50) {
        return $this->where($start, $end)
            ->select('url', \DB::raw('sum(count) as hits'))
            ->groupBy('url')
            ->orderBy('hits', 'desc')
            ->limit($limit)
            ->get();
    }

    /**
     * Sum hits in the given period.
     *
     * @param Carbon $start
     * @param Carbon|null $end
     * @param string $url
     *
     * @return mixed
     */
    public function countOverallVisits(Carbon $start, Carbon $end = null, $url = null) {
        return $this->where($start, $end, $url)->sum('count');
    }

    /**
     * Count records in the given period.
     *
     * @param Carbon $start
     * @param Carbon|null $end
     * @param string $url
     *
     * @return mixed
     */
    public function countUniqueVisits(Carbon $start, Carbon $end = null, $url = null) {
        return $this->where($start, $end, $url)->count('count');
    }

    /**
     * Return an array of date/hits in the given period.
     *
     * @param Carbon $start
     * @param Carbon|null   $end
     * @param string $url
     *
     * @return mixed
     */
    public function getVisitsTrendDaily(Carbon $start, Carbon $end = null, $url = null) {
        return $this->where($start, $end, $url)
            ->select('date', \DB::raw('sum(count) as hits'))
            ->groupBy('date')
            ->orderBy('date')
            ->get();
    }

    public function getVisitsTrendMonthly(Carbon $start, Carbon $end = null, $url = null) {
        // @TODO probably month() function breaking performances.

        return $this->where($start, $end, $url)
            ->select(\DB::raw('month(date) as month'), \DB::raw('sum(count) as hits'))
            ->groupBy(\DB::raw('month(date)'))
            ->get();
    }

    public function dump() {
        \DB::transaction(function(){
            $this->executeDump();
        });
    }

    public function executeDump() {
        // Dump records.
        foreach (\DB::table('visits_buffer')->get() as $bufferRecord) {
            $visit = new Visit((array)$bufferRecord);
            $visit->save();
        }

        // Cleanup buffer.
        \DB::table('visits_buffer')->truncate();
    }
}